[ARVADOS] updated: 68cd78ca1a20d80e0ab90d125df305f30b606f85

[git at public.curoverse.com]

Summary of changes:
 sdk/python/arvados/arvfile.py    | 6 +++---
 sdk/python/arvados/collection.py | 6 +++---
 2 files changed, 6 insertions(+), 6 deletions(-)

       via  68cd78ca1a20d80e0ab90d125df305f30b606f85 (commit)
      from  5109db362064053ed6711169d6c414b2cb4e22fb (commit)

Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.


commit 68cd78ca1a20d80e0ab90d125df305f30b606f85
Author: Peter Amstutz <peter.amstutz at curoverse.com>
Date:   Tue Dec 30 17:10:24 2014 -0500

    3198: Bugfixes.  Working on benchmarking upload/download performance.

diff --git a/sdk/python/arvados/arvfile.py b/sdk/python/arvados/arvfile.py
index 8369272..61ba3e0 100644
--- a/sdk/python/arvados/arvfile.py
+++ b/sdk/python/arvados/arvfile.py
@@ -348,8 +348,10 @@ class BlockManager(object):
             return
         if self._prefetch_threads is None:
             self._prefetch_queue = Queue.Queue()
-            self._prefetch_threads = [threading.Thread(target=worker, args=(self,))]
+            self._prefetch_threads = [threading.Thread(target=worker, args=(self,)),
+                                      threading.Thread(target=worker, args=(self,))]
             self._prefetch_threads[0].start()
+            self._prefetch_threads[1].start()
         self._prefetch_queue.put(locator)
 
 class ArvadosFile(object):
@@ -393,8 +395,6 @@ class ArvadosFile(object):
     def readfrom(self, offset, size, num_retries):
         if size == 0 or offset >= self.size():
             return ''
-        if self._keep is None:
-            self._keep = KeepClient(num_retries=num_retries)
         data = []
 
         for lr in locators_and_ranges(self._segments, offset, size + config.KEEP_BLOCK_SIZE):
diff --git a/sdk/python/arvados/collection.py b/sdk/python/arvados/collection.py
index 6602ed1..5857fb2 100644
--- a/sdk/python/arvados/collection.py
+++ b/sdk/python/arvados/collection.py
@@ -641,7 +641,7 @@ class ResumableCollectionWriter(CollectionWriter):
 
 
 class Collection(CollectionBase):
-    def __init__(self, parent=None, manifest_locator_or_text=None, api_client=None,
+    def __init__(self, manifest_locator_or_text=None, parent=None, api_client=None,
                  keep_client=None, num_retries=0, block_manager=None):
 
         self._parent = parent
@@ -836,11 +836,11 @@ class Collection(CollectionBase):
 
     @_populate_first
     def __iter__(self):
-        self._items.iterkeys()
+        return self._items.iterkeys()
 
     @_populate_first
     def iterkeys(self):
-        self._items.iterkeys()
+        return self._items.iterkeys()
 
     @_populate_first
     def __getitem__(self, k):

-----------------------------------------------------------------------


hooks/post-receive
--