4904: Add feature to arv-ws to run a command when something is added or removed from...

[arvados.git] / sdk / python / arvados / events.py

diff --git a/sdk/python/arvados/events.py b/sdk/python/arvados/events.py
index d1abc0f7de0cd1a7c35cffb254605be302e85fd1..1feb1fe7e500cda7c6564ade70c42a31ee7a1ff9 100644 (file)
--- a/sdk/python/arvados/events.py
+++ b/sdk/python/arvados/events.py
@@ -48,6 +48,7 @@ class EventClient(WebSocketClient):
 class PollClient(threading.Thread):
     def __init__(self, api, filters, on_event, poll_time):
         super(PollClient, self).__init__()
+        self.daemon = True
         self.api = api
         if filters:
             self.filters = [filters]
@@ -79,7 +80,8 @@ class PollClient(threading.Thread):
             self.stop.wait(self.poll_time)
 
     def run_forever(self):
-        self.stop.wait()
+        while not self.stop.is_set():
+            self.stop.wait(1)
 
     def close(self):
         self.stop.set()