We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f0fbb66 commit 783656eCopy full SHA for 783656e
pydra/engine/submitter.py
@@ -525,9 +525,16 @@ def update_status(self) -> None:
525
return
526
# Check to see if any previously queued tasks have completed
527
for index, task in list(self.queued.items()):
528
- if task.done:
+ try:
529
+ is_done = task.done
530
+ except ValueError:
531
+ errored = True
532
+ is_done = False
533
+ else:
534
+ errored = False
535
+ if is_done:
536
self.successful[task.state_index] = self.queued.pop(index)
- elif task.errored:
537
+ elif task.errored or errored:
538
self.errored[task.state_index] = self.queued.pop(index)
539
elif task.run_start_time:
540
self.running[task.state_index] = (
0 commit comments