import ssl
import re
import config
+import logging
+
+_logger = logging.getLogger('arvados.events')
class EventClient(WebSocketClient):
def __init__(self, url, filters, on_event):
pass
def subscribe(api, filters, on_event):
+ ws = None
try:
url = "{}?api_token={}".format(api._rootDesc['websocketUrl'], config.get('ARVADOS_API_TOKEN'))
ws = EventClient(url, filters, on_event)
ws.connect()
return ws
- except:
- ws.close_connection()
+ except Exception:
+ if (ws):
+ ws.close_connection()
+ raise