Skip to content

Commit 6cdafc6

Browse files
author
Luke Bakken
committed
add TODO FUTURE notes
1 parent c151007 commit 6cdafc6

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

riak/client/operations.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -263,6 +263,8 @@ def stream_index(self, bucket, index, startkey, endkey=None,
263263
:rtype: :class:`~riak.client.index_page.IndexPage`
264264
265265
"""
266+
# TODO FUTURE: implement "retry on connection closed"
267+
# as in stream_mapred
266268
_validate_timeout(timeout, infinity_ok=True)
267269

268270
page = IndexPage(self, bucket, index, startkey, endkey,
@@ -335,6 +337,8 @@ def paginate_stream_index(self, bucket, index, startkey, endkey=None,
335337
:class:`~riak.client.index_page.IndexPage`
336338
337339
"""
340+
# TODO FUTURE: implement "retry on connection closed"
341+
# as in stream_mapred
338342
page = self.stream_index(bucket, index, startkey,
339343
endkey=endkey,
340344
max_results=max_results,

0 commit comments

Comments
 (0)