Skip to content

Commit ff9a371

Browse files
author
Luke Bakken
committed
Move code into try block
1 parent 93253ef commit ff9a371

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

riak/client/transport.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -106,9 +106,9 @@ def _stream_with_retry(self, make_op):
106106
while True:
107107
resource = self._acquire()
108108
transport = resource.object
109-
streaming_op = make_op(transport)
110-
streaming_op.attach(resource)
111109
try:
110+
streaming_op = make_op(transport)
111+
streaming_op.attach(resource)
112112
for item in streaming_op:
113113
yield item
114114
break

0 commit comments

Comments
 (0)