def keeppath(v):
if arvados.util.keep_locator_pattern.match(v):
- job_order_object[k] = "file://%s/%s" % (os.environ['TASK_KEEPMOUNT'], v)
+ return "file://%s/%s" % (os.environ['TASK_KEEPMOUNT'], v)
adjustFiles(job_order_object, keeppath)
body = {"owner_uuid": project, "manifest_text": collection.manifest_text()}
if name is not None:
body["name"] = name
- item = api.collections().create(body=body).execute()
+ item = api.collections().create(body=body, ensure_unique_name=True).execute()
pdh = item["portable_data_hash"]
logger.info("Uploaded to %s", item["uuid"])