#
# SPDX-License-Identifier: Apache-2.0
-from __future__ import print_function
-import sys
-import logging
import argparse
-import arvados
import json
+import logging
+import signal
+import sys
+
+import arvados
from arvados.events import subscribe
from arvados._version import __version__
-import signal
+from . import _util as arv_cmd
def main(arguments=None):
logger = logging.getLogger('arvados.arv-ws')
- parser = argparse.ArgumentParser()
+ parser = argparse.ArgumentParser(parents=[arv_cmd.retry_opt])
parser.add_argument('--version', action='version',
version="%s %s" % (sys.argv[0], __version__),
help='Print version and exit.')
filters = new_filters
known_component_jobs = pipeline_jobs
- api = arvados.api('v1')
+ api = arvados.api('v1', num_retries=args.retries)
if args.uuid:
filters += [ ['object_uuid', '=', args.uuid] ]