- outputObj = runner.arvExecutor(t, job_order_object, **vars(args))
-
- files = {}
- def capture(fileobj):
- path = fileobj["location"]
- sp = path.split("/")
- col = sp[0][5:]
- if col not in files:
- files[col] = set()
- files[col].add("/".join(sp[1:]))
- fileobj["location"] = path
-
- adjustFileObjs(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(fileobj):
- fileobj["location"] = "/".join(fileobj["location"].split("/")[1:])
-
- adjustFileObjs(outputObj, makeRelative)