From b0e7987af4ac6ae6ea3250e9dafa4ecf58544770 Mon Sep 17 00:00:00 2001 From: Peter Amstutz Date: Tue, 7 Jun 2016 16:17:49 -0400 Subject: [PATCH] 9275: Initial pipeline/job component update from response --- sdk/cwl/arvados_cwl/__init__.py | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/sdk/cwl/arvados_cwl/__init__.py b/sdk/cwl/arvados_cwl/__init__.py index f2b38daab4..adf93722fe 100644 --- a/sdk/cwl/arvados_cwl/__init__.py +++ b/sdk/cwl/arvados_cwl/__init__.py @@ -194,11 +194,7 @@ class ArvadosJob(object): self.arvrunner.jobs[response["uuid"]] = self - self.arvrunner.pipeline["components"][self.name] = {"job": response} - self.arvrunner.pipeline = self.arvrunner.api.pipeline_instances().update(uuid=self.arvrunner.pipeline["uuid"], - body={ - "components": self.arvrunner.pipeline["components"] - }).execute(num_retries=self.arvrunner.num_retries) + self.update_pipeline_component(response) logger.info("Job %s (%s) is %s", self.name, response["uuid"], response["state"]) -- 2.30.2