X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/511e36db2a5ed0380752d15e9c60364483d0e9f0..5c9aedbd8e623a518f5e1a92e4064a25ddd66353:/sdk/cwl/arvados_cwl/runner.py diff --git a/sdk/cwl/arvados_cwl/runner.py b/sdk/cwl/arvados_cwl/runner.py index 155c6a0503..cf2f1db997 100644 --- a/sdk/cwl/arvados_cwl/runner.py +++ b/sdk/cwl/arvados_cwl/runner.py @@ -69,25 +69,19 @@ def upload_dependencies(arvrunner, name, document_loader, set(("$include", "$schemas", "location")), loadref) - files = [] - def visitFiles(path): - files.append(path) - - adjustFileObjs(sc, visitFiles) - adjustDirObjs(sc, visitFiles) - - normalizeFilesDirs(files) + normalizeFilesDirs(sc) if "id" in workflowobj: - files.append({"class": "File", "location": workflowobj["id"]}) + sc.append({"class": "File", "location": workflowobj["id"]}) - mapper = ArvPathMapper(arvrunner, files, "", + mapper = ArvPathMapper(arvrunner, sc, "", "keep:%s", "keep:%s/%s", name=name) def setloc(p): - p["location"] = mapper.mapper(p["location"]).target + if not p["location"].startswith("_:") and not p["location"].startswith("keep:"): + p["location"] = mapper.mapper(p["location"]).target adjustFileObjs(workflowobj, setloc) adjustDirObjs(workflowobj, setloc)