Commit 511ce997 by rfkelly0

don't attempt to deepcopy lock objects, they don't like that

parent cc5c9236
...@@ -72,7 +72,7 @@ class RemoteFileBuffer(object): ...@@ -72,7 +72,7 @@ class RemoteFileBuffer(object):
self.closed = False self.closed = False
self._flushed = False self._flushed = False
if hasattr(fs,"_lock"): if hasattr(fs,"_lock"):
self._lock = copy.deepcopy(fs._lock) self._lock = fs._lock.__class__()
else: else:
self._lock = threading.RLock() self._lock = threading.RLock()
if rfile is not None: if rfile is not None:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment