-import argparse
-import sys
-
-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
-
-api = arvados.api('v1', cache=False)
-
-ws = None
-try:
- ws = subscribe(api, filters, lambda ev: on_message(ev))
- ws.run_forever()
-except:
- if (ws):
- ws.close_connection()
- else:
- sys.exc_info()