X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/5030cca0ec767bf6e1ba630f91938130731ed6cc..a7f12322bab34a27863d90de9ddb95f69697bf29:/sdk/python/bin/arv-ws

diff --git a/sdk/python/bin/arv-ws b/sdk/python/bin/arv-ws
index 07216879a9..ce7f066ec7 100755
--- a/sdk/python/bin/arv-ws
+++ b/sdk/python/bin/arv-ws
@@ -1,34 +1,30 @@
 #!/usr/bin/env python
 
-import argparse
 import sys
+import logging
+import argparse
+import arvados
+from arvados.events import subscribe
+
+logger = logging.getLogger('arvados.arv-ws')
 
 parser = argparse.ArgumentParser()
 parser.add_argument('-u', '--uuid', type=str, default="")
 args = parser.parse_args()
 
-def on_message(ev):
-  print "\n", ev
-
 filters = []
-if len(args.uuid)>0:
-  filter1 = []
-  filter1.append ('object_uuid')
-  filter1.append ('=')
-  filter1.append (args.uuid)
-  filters.append (filter1)
-
-import arvados
-from arvados.events import subscribe
+if len(args.uuid)>0: filters = [ ['object_uuid', '=', args.uuid] ]
 
 api = arvados.api('v1', cache=False)
 
+def on_message(ev):
+  print "\n", ev
+
 ws = None
 try:
   ws = subscribe(api, filters, lambda ev: on_message(ev))
   ws.run_forever()
-except:
+except Exception:
+  logger.exception('')
   if (ws):
     ws.close_connection()
-  else:
-    sys.exc_info()