Hotfix: use a recursive lock for closed_lock so that EventClient.close() can be

called from on_event(). refs #7654

diff --git a/sdk/python/arvados/events.py b/sdk/python/arvados/events.py
index 410463be9dd97b015d070046a7d1f70b00fb570e..07c6a47619d3a696774db1a547f228314adb1455 100644 (file)
--- a/sdk/python/arvados/events.py
+++ b/sdk/python/arvados/events.py
@@ -29,7 +29,7 @@ class EventClient(WebSocketClient):
         self.filters = filters
         self.on_event = on_event
         self.last_log_id = last_log_id
         self.filters = filters
         self.on_event = on_event
         self.last_log_id = last_log_id

-        self.closed_lock = threading.Lock()
+        self.closed_lock = threading.RLock()

         self.closed = False
 
     def opened(self):
         self.closed = False
 
     def opened(self):