X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/4cd89bd1767bece226c412ae7c9ea37669e8706b..2b27132d13fd72f29dbab2297f0d2dc1c110eed1:/sdk/cwl/arvados_cwl/__init__.py diff --git a/sdk/cwl/arvados_cwl/__init__.py b/sdk/cwl/arvados_cwl/__init__.py index 024e9d0861..3b14701a9b 100644 --- a/sdk/cwl/arvados_cwl/__init__.py +++ b/sdk/cwl/arvados_cwl/__init__.py @@ -11,6 +11,7 @@ import threading import hashlib import copy import json +import re from functools import partial import pkg_resources # part of setuptools @@ -314,6 +315,10 @@ class ArvCwlRunner(object): body={ 'output': self.final_output_collection.portable_data_hash(), }).execute(num_retries=self.num_retries) + self.api.collections().update(uuid=self.final_output_collection.manifest_locator(), + body={ + 'is_trashed': True + }).execute(num_retries=self.num_retries) except Exception as e: logger.info("Setting container output: %s", e) elif self.work_api == "jobs" and "TASK_UUID" in os.environ: @@ -625,6 +630,7 @@ def arg_parser(): # type: () -> argparse.ArgumentParser def add_arv_hints(): cache = {} + cwltool.draft2tool.ACCEPTLIST_EN_RELAXED_RE = re.compile(r".*") res = pkg_resources.resource_stream(__name__, 'arv-cwl-schema.yml') cache["http://arvados.org/cwl"] = res.read() res.close()