Merge branch '5030-hide-graph-until-data' closes #5030

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

diff --git a/sdk/python/arvados/events.py b/sdk/python/arvados/events.py
index 268692637afb7a45721322f1617b3aea50788d60..09f2a871a966522201f5808e09fb37a820b1baf5 100644 (file)
--- a/sdk/python/arvados/events.py
+++ b/sdk/python/arvados/events.py
@@ -65,6 +65,7 @@ class PollClient(threading.Thread):
             self.filters = [[]]
         self.on_event = on_event
         self.poll_time = poll_time
+        self.daemon = True
         self.stop = threading.Event()
 
     def run(self):
@@ -129,12 +130,17 @@ def _subscribe_websocket(api, filters, on_event):
             client.close_connection()
 
 def subscribe(api, filters, on_event, poll_fallback=15):
-    '''
-    api: a client object retrieved from arvados.api(). The caller should not use this client object for anything else after calling subscribe().
-    filters: Initial subscription filters.
-    on_event: The callback when a message is received.
-    poll_fallback: If websockets are not available, fall back to polling every N seconds.  If poll_fallback=False, this will return None if websockets are not available.
-    '''
+    """
+    :api:
+      a client object retrieved from arvados.api(). The caller should not use this client object for anything else after calling subscribe().
+    :filters:
+      Initial subscription filters.
+    :on_event:
+      The callback when a message is received.
+    :poll_fallback:
+      If websockets are not available, fall back to polling every N seconds.  If poll_fallback=False, this will return None if websockets are not available.
+    """
+
     if not poll_fallback:
         return _subscribe_websocket(api, filters, on_event)