X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/08698803d8b324ba9a889a3aa41559d782bcc4bf..9486b15595a667742ef541d3f31f78507afea8e7:/sdk/cwl/arvados_cwl/fsaccess.py diff --git a/sdk/cwl/arvados_cwl/fsaccess.py b/sdk/cwl/arvados_cwl/fsaccess.py index d258937477..e44e7a9282 100644 --- a/sdk/cwl/arvados_cwl/fsaccess.py +++ b/sdk/cwl/arvados_cwl/fsaccess.py @@ -1,5 +1,6 @@ import fnmatch import os +import errno import cwltool.stdfsaccess from cwltool.pathmapper import abspath @@ -83,7 +84,7 @@ class CollectionFsAccess(cwltool.stdfsaccess.StdFsAccess): collection, rest = self.get_collection(fn) if collection: if rest: - return isinstance(collection.find(rest), arvados.collection.Collection) + return isinstance(collection.find(rest), arvados.collection.RichCollectionBase) else: return True else: @@ -91,11 +92,15 @@ class CollectionFsAccess(cwltool.stdfsaccess.StdFsAccess): def listdir(self, fn): # type: (unicode) -> List[unicode] collection, rest = self.get_collection(fn) - if rest: - dir = collection.find(rest) - else: - dir = collection if collection: + if rest: + dir = collection.find(rest) + else: + dir = collection + if dir is None: + raise IOError(errno.ENOENT, "Directory '%s' in '%s' not found" % (rest, collection.portable_data_hash())) + if not isinstance(dir, arvados.collection.RichCollectionBase): + raise IOError(errno.ENOENT, "Path '%s' in '%s' is not a Directory" % (rest, collection.portable_data_hash())) return [abspath(l, fn) for l in dir.keys()] else: return super(CollectionFsAccess, self).listdir(fn)