- outputObj = runner.arvExecutor(t, job_order_object, "", args, cwl_runner_job={"uuid": arvados.current_job()["uuid"], "state": arvados.current_job()["state"]})
-
- files = {}
- def capture(path):
- sp = path.split("/")
- col = sp[0][5:]
- if col not in files:
- files[col] = set()
- files[col].add("/".join(sp[1:]))
- return path
-
- adjustFiles(outputObj, capture)
-
- final = arvados.collection.Collection()
-
- for k,v in files.iteritems():
- with arvados.collection.Collection(k) as c:
- for f in c:
- final.copy(f, f, c, True)
-
- def makeRelative(path):
- return "/".join(path.split("/")[1:])
-
- adjustFiles(outputObj, makeRelative)
+ args.ignore_docker_for_reuse = False
+ args.basedir = os.getcwd()
+ args.cwl_runner_job={"uuid": arvados.current_job()["uuid"], "state": arvados.current_job()["state"]}
+ outputObj = runner.arv_executor(t, job_order_object, **vars(args))