X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/c23ee1444f21e6a5f2af9f058b610cfa301059cf..ef56ac56a0bac0710a486c0e5e9cdd3199eddc61:/sdk/python/bin/arv-ws?ds=sidebyside diff --git a/sdk/python/bin/arv-ws b/sdk/python/bin/arv-ws index 58b628145f..4e663cef1b 100755 --- a/sdk/python/bin/arv-ws +++ b/sdk/python/bin/arv-ws @@ -1,30 +1,4 @@ #!/usr/bin/env python -import sys -import logging -import argparse -import arvados -from arvados.events import subscribe - -parser = argparse.ArgumentParser() -parser.add_argument('-u', '--uuid', type=str, default="") -args = parser.parse_args() - -filters = [] -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 KeyboardInterrupt: - print '' # don't log it -except: - logging.exception('') - if (ws): - ws.close_connection() +from arvados.commands.ws import main +main()