X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/4da7a9b5c11caf085c14cbf0eacdc16b6f6d7fa5..34d4fa002c738c7a6ec1fdab4e12e748c8967f92:/sdk/cwl/arvados_cwl/runner.py?ds=inline diff --git a/sdk/cwl/arvados_cwl/runner.py b/sdk/cwl/arvados_cwl/runner.py index fb5d036e94..053c99502b 100644 --- a/sdk/cwl/arvados_cwl/runner.py +++ b/sdk/cwl/arvados_cwl/runner.py @@ -13,8 +13,7 @@ from StringIO import StringIO from schema_salad.sourceline import SourceLine -import cwltool.draft2tool -from cwltool.draft2tool import CommandLineTool +from cwltool.command_line_tool import CommandLineTool import cwltool.workflow from cwltool.process import get_feature, scandeps, UnsupportedRequirement, normalizeFilesDirs, shortname from cwltool.load_tool import fetch_document @@ -317,7 +316,8 @@ class Runner(object): def __init__(self, runner, tool, job_order, enable_reuse, output_name, output_tags, submit_runner_ram=0, name=None, on_error=None, submit_runner_image=None, - intermediate_output_ttl=0, merged_map=None): + intermediate_output_ttl=0, merged_map=None, priority=None, + secret_store=None): self.arvrunner = runner self.tool = tool self.job_order = job_order @@ -337,6 +337,8 @@ class Runner(object): self.on_error = on_error self.jobs_image = submit_runner_image or "arvados/jobs:"+__version__ self.intermediate_output_ttl = intermediate_output_ttl + self.priority = priority + self.secret_store = secret_store if submit_runner_ram: self.submit_runner_ram = submit_runner_ram