fix infinite loop in flush_data
authorTom Clegg <tom@clinicalfuture.com>
Tue, 10 Sep 2013 05:19:56 +0000 (01:19 -0400)
committerTom Clegg <tom@clinicalfuture.com>
Sun, 15 Sep 2013 21:47:43 +0000 (17:47 -0400)
sdk/python/arvados.py

index a7ed7552b53ba686a2769289503a87008d557a68..5a15250a8d323d04c144b3b4d1077016e70e9b0f 100644 (file)
@@ -596,6 +596,7 @@ class CollectionWriter:
         if data_buffer != '':
             self._current_stream_locators += [Keep.put(data_buffer[0:self.KEEP_BLOCK_SIZE])]
             self._data_buffer = [data_buffer[self.KEEP_BLOCK_SIZE:]]
+            self._data_buffer_len = len(self._data_buffer[0])
     def start_new_file(self, newfilename=None):
         self.finish_current_file()
         self.set_current_file_name(newfilename)