X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/1f5fee78438f06ec9531939247321dfb30af2b1a..495a7df016f63ae348000b1c046f8e1c5f1c5903:/sdk/cwl/arvados_cwl/runner.py diff --git a/sdk/cwl/arvados_cwl/runner.py b/sdk/cwl/arvados_cwl/runner.py index eaa69c423e..1c3625e26b 100644 --- a/sdk/cwl/arvados_cwl/runner.py +++ b/sdk/cwl/arvados_cwl/runner.py @@ -167,7 +167,7 @@ def arvados_jobs_image(arvrunner): class Runner(object): def __init__(self, runner, tool, job_order, enable_reuse, output_name, output_tags, submit_runner_ram=0, - name=None): + name=None, on_error=None): self.arvrunner = runner self.tool = tool self.job_order = job_order @@ -178,6 +178,7 @@ class Runner(object): self.output_name = output_name self.output_tags = output_tags self.name = name + self.on_error = on_error if submit_runner_ram: self.submit_runner_ram = submit_runner_ram @@ -225,7 +226,7 @@ class Runner(object): api_client=self.arvrunner.api, keep_client=self.arvrunner.keep_client, num_retries=self.arvrunner.num_retries) - done.logtail(logc, logger, "%s error log:" % self.arvrunner.label(self)) + done.logtail(logc, logger, "%s error log:" % self.arvrunner.label(self), maxlen=40) self.final_output = record["output"] outc = arvados.collection.CollectionReader(self.final_output,