X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/5dfc48c1a1697d9c29eac0061a491e96c9b72441..10b3fe2ae3a37ee473684177aa6e4e9f090a230e:/sdk/cwl/arvados_cwl/arvcontainer.py diff --git a/sdk/cwl/arvados_cwl/arvcontainer.py b/sdk/cwl/arvados_cwl/arvcontainer.py index f7a523a6ce..20601243b1 100644 --- a/sdk/cwl/arvados_cwl/arvcontainer.py +++ b/sdk/cwl/arvados_cwl/arvcontainer.py @@ -15,8 +15,11 @@ from .arvdocker import arv_docker_get_image from . import done from .runner import Runner, arvados_jobs_image, packed_workflow, trim_listing from .fsaccess import CollectionFetcher +from .pathmapper import NoFollowPathMapper +from .perf import Perf logger = logging.getLogger('arvados.cwl-runner') +metrics = logging.getLogger('arvados.cwl-runner.metrics') class ArvadosContainer(object): """Submit and manage a Crunch container request for executing a CWL CommandLineTool.""" @@ -50,23 +53,54 @@ class ArvadosContainer(object): dirs = set() for f in self.pathmapper.files(): - _, p, tp = self.pathmapper.mapper(f) - if tp == "Directory" and '/' not in p[6:]: + pdh, p, tp = self.pathmapper.mapper(f) + if tp == "Directory" and '/' not in pdh: mounts[p] = { "kind": "collection", - "portable_data_hash": p[6:] + "portable_data_hash": pdh[5:] } - dirs.add(p[6:]) + dirs.add(pdh) + for f in self.pathmapper.files(): - _, p, tp = self.pathmapper.mapper(f) - if p[6:].split("/")[0] not in dirs: + res, p, tp = self.pathmapper.mapper(f) + pdh, path = res[5:].split("/", 1) + if pdh not in dirs: mounts[p] = { "kind": "collection", - "portable_data_hash": p[6:] + "portable_data_hash": pdh } - - if self.generatefiles["listing"]: - raise UnsupportedRequirement("InitialWorkDirRequirement not supported with --api=containers") + if path: + mounts[p]["path"] = path + + with Perf(metrics, "generatefiles %s" % self.name): + if self.generatefiles["listing"]: + vwd = arvados.collection.Collection(api_client=self.arvrunner.api, + keep_client=self.arvrunner.keep_client, + num_retries=self.arvrunner.num_retries) + generatemapper = NoFollowPathMapper([self.generatefiles], "", "", + separateDirs=False) + + with Perf(metrics, "createfiles %s" % self.name): + for f, p in generatemapper.items(): + if not p.target: + pass + elif p.type in ("File", "Directory"): + source, path = self.arvrunner.fs_access.get_collection(p.resolved) + vwd.copy(path, p.target, source_collection=source) + elif p.type == "CreateFile": + with vwd.open(p.target, "w") as n: + n.write(p.resolved.encode("utf-8")) + + with Perf(metrics, "generatefiles.save_new %s" % self.name): + vwd.save_new() + + for f, p in generatemapper.items(): + if not p.target: + continue + mountpoint = "%s/%s" % (self.outdir, p.target) + mounts[mountpoint] = {"kind": "collection", + "portable_data_hash": vwd.portable_data_hash(), + "path": p.target} container_request["environment"] = {"TMPDIR": self.tmpdir, "HOME": self.outdir} if self.environment: