streaming_op may not be initialized if make_op throws an exception

Author: Luke Bakken

riak/client/transport.py

@@ -106,6 +106,7 @@ def _stream_with_retry(self, make_op):
         while True:
             resource = self._acquire()
             transport = resource.object
+            streaming_op = None
             try:
                 streaming_op = make_op(transport)
                 streaming_op.attach(resource)
@@ -122,7 +123,8 @@ def _stream_with_retry(self, make_op):
                     raise
             finally:
                 first_try = False
-                streaming_op.close()
+                if streaming_op:
+                    streaming_op.close()
 
     def _with_retries(self, pool, fn):
         """