Skip to content
This repository has been archived by the owner on Mar 16, 2023. It is now read-only.

Commit

Permalink
Merge branch 'master' of ssh://bitbucket.astrazeneca.net:7999/com/ico…
Browse files Browse the repository at this point in the history
…los into development

Conflicts:
	src/icolos/core/workflow_steps/pmx/base.py
  • Loading branch information
jharrymoore committed Feb 16, 2022
2 parents 46e2050 + 1b3140b commit db78104
Showing 1 changed file with 7 additions and 1 deletion.
8 changes: 7 additions & 1 deletion src/icolos/core/workflow_steps/pmx/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -298,7 +298,7 @@ def _execute_pmx_step_parallel(

if result_checker is not None:
batch_results = result_checker(jobs)

good_results = 0
for task, result in zip(next_batch, batch_results):
# returns boolean arrays: False => failed job
for subtask, sub_result in zip(task, result):
Expand All @@ -319,6 +319,12 @@ def _execute_pmx_step_parallel(
print("setting status to failed!")
else:
subtask.set_status_success()
good_results += 1
self._logger.log(
f"EXECUTION SUMMARY: Completed {good_results} jobs successfully (out of {len(jobs) * len(jobs)[0]} jobs for step {step_id}",
_LE.INFO,
)

else:
self._logger.log(
f"Step {step_id} is running without a result checker - failed executions will be ignored!",
Expand Down

0 comments on commit db78104

Please sign in to comment.