Merge pull request #293 from lgray/FileSource_futures

Propagate FileSource futures setup to threadlocal
scikit-hep · Jun 24, 2019 · 349b3d8 · 349b3d8
2 parents 2d7b0da + 1b6fb9b
commit 349b3d8
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/uproot/source/file.py b/uproot/source/file.py
@@ -18,6 +18,7 @@ class FileSource(uproot.source.chunked.ChunkedSource):
 
     def __init__(self, path, *args, **kwds):
         self._size = None
+        self._parallel = kwds['parallel']
         super(FileSource, self).__init__(os.path.expanduser(path), *args, **kwds)
 
     def size(self):
@@ -31,6 +32,7 @@ def threadlocal(self):
         out._chunkbytes = self._chunkbytes
         out.cache = self.cache
         out._source = None             # local file connections are *not shared* among threads (they're *not* thread-safe)
+        out._setup_futures(self._parallel)
         return out
 
     def _open(self):