Accept data from a generator in arvados.CollectionWriter.write()
authorTom Clegg <tom@clinicalfuture.com>
Fri, 29 Nov 2013 16:35:04 +0000 (08:35 -0800)
committerTom Clegg <tom@clinicalfuture.com>
Tue, 3 Dec 2013 22:32:42 +0000 (14:32 -0800)
sdk/python/arvados.py

index f51b768d5b1b4d8d8421f075a63da3a982629872..354ef629f8641d27f20935c4b57de0df5808520c 100644 (file)
@@ -713,6 +713,10 @@ class CollectionWriter(object):
         map(lambda x: self.write_directory_tree(*x), todo)
 
     def write(self, newdata):
+        if hasattr(newdata, '__iter__'):
+            for s in newdata:
+                self.write(s)
+            return
         self._data_buffer += [newdata]
         self._data_buffer_len += len(newdata)
         self._current_stream_length += len(newdata)