From 41a6bedfa3c83a7a15e103dae8a3de37827cb178 Mon Sep 17 00:00:00 2001 From: Riccardo Murri Date: Mon, 22 Jan 2018 15:52:23 +0100 Subject: [PATCH] ParallelTaskCollection.update_job_state(): Do not replicate code from `TaskCollection.update_job_state()` --- gc3libs/workflow.py | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/gc3libs/workflow.py b/gc3libs/workflow.py index fe7af4df..3e60f3cc 100755 --- a/gc3libs/workflow.py +++ b/gc3libs/workflow.py @@ -878,11 +878,7 @@ def update_state(self, **extra_args): """ Update state of all tasks in the collection. """ - for task in self.tasks: - # gc3libs.log.debug("Updating state of %s in collection %s ..." - # % (task, self)) - if task.execution.state not in [Run.State.NEW, Run.State.TERMINATED]: - task.update_state(**extra_args) + super(ParallelTaskCollection, self).update_state() self.execution.state = self._state() if self.execution.state == Run.State.TERMINATED: self.execution.returncode = (0, 0)