Skip to content

Commit

Permalink
ParallelTaskCollection.update_job_state(): Do not replicate code from…
Browse files Browse the repository at this point in the history
… `TaskCollection.update_job_state()`
  • Loading branch information
riccardomurri committed Jan 22, 2018
1 parent c0c94de commit 41a6bed
Showing 1 changed file with 1 addition and 5 deletions.
6 changes: 1 addition & 5 deletions gc3libs/workflow.py
Expand Up @@ -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)
Expand Down

0 comments on commit 41a6bed

Please sign in to comment.