X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/5cf55ab0cfe55cbd803b61736276044f7008bfa4..6e0abcdabb14bcd21695420d3cfab0d57362a2be:/sdk/cwl/arvados_cwl/fsaccess.py diff --git a/sdk/cwl/arvados_cwl/fsaccess.py b/sdk/cwl/arvados_cwl/fsaccess.py index d2d38b00c3..d258937477 100644 --- a/sdk/cwl/arvados_cwl/fsaccess.py +++ b/sdk/cwl/arvados_cwl/fsaccess.py @@ -1,14 +1,14 @@ import fnmatch import os -import cwltool.process +import cwltool.stdfsaccess from cwltool.pathmapper import abspath import arvados.util import arvados.collection import arvados.arvfile -class CollectionFsAccess(cwltool.process.StdFsAccess): +class CollectionFsAccess(cwltool.stdfsaccess.StdFsAccess): """Implement the cwltool FsAccess interface for Arvados Collections.""" def __init__(self, basedir, api_client=None): @@ -104,3 +104,12 @@ class CollectionFsAccess(cwltool.process.StdFsAccess): if paths and paths[-1].startswith("keep:") and arvados.util.keep_locator_pattern.match(paths[-1][5:]): return paths[-1] return os.path.join(path, *paths) + + def realpath(self, path): + if path.startswith("$(task.tmpdir)") or path.startswith("$(task.outdir)"): + return path + collection, rest = self.get_collection(path) + if collection: + return path + else: + return os.path.realpath(path)