runnerjob.run(submitargs)
return (runnerjob.uuid, "success")
- self.poll_api = arvados.api('v1', timeout=kwargs["http_timeout"])
+ self.poll_api = arvados.api('v1', timeout=runtimeContext.http_timeout)
self.polling_thread = threading.Thread(target=self.poll_states)
self.polling_thread.start()
default=4, help="Number of threads to use for job submit and output collection.")
parser.add_argument("--http-timeout", type=int,
- default=5*60, dest="http_timeout", help="Http timeout. Default is 5 minutes.")
+ default=5*60, dest="http_timeout", help="API request timeout in seconds. Default is 300 seconds (5 minutes).")
exgroup = parser.add_mutually_exclusive_group()
exgroup.add_argument("--trash-intermediate", action="store_true",
runtimeContext = ArvRuntimeContext(vars(arvargs))
runtimeContext.make_fs_access = partial(CollectionFsAccess,
collection_cache=runner.collection_cache)
+ runtimeContext.http_timeout = arvargs.http_timeout
return cwltool.main.main(args=arvargs,
stdout=stdout,
self.cwl_runner_job = None
self.storage_classes = "default"
self.current_container = None
+ self.http_timeout = 300
super(ArvRuntimeContext, self).__init__(kwargs)