X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/1a3ec903e591304b72bd0d394219729ac76bfed0..d940d88f991c14785110855ba0ee79ea5f401276:/sdk/python/bin/arv-ws diff --git a/sdk/python/bin/arv-ws b/sdk/python/bin/arv-ws index 07216879a9..2b601296b4 100755 --- a/sdk/python/bin/arv-ws +++ b/sdk/python/bin/arv-ws @@ -1,34 +1,7 @@ -#!/usr/bin/env python +#!/usr/bin/env python3 +# Copyright (C) The Arvados Authors. All rights reserved. +# +# SPDX-License-Identifier: Apache-2.0 -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() +from arvados.commands.ws import main +main()