Skip to content
This repository has been archived by the owner on Jan 2, 2024. It is now read-only.

Commit

Permalink
added submission status tests on test_orchestrator.py
Browse files Browse the repository at this point in the history
  • Loading branch information
Toan Quach authored and Toan Quach committed Nov 28, 2023
1 parent a08bfa4 commit c3f2a21
Show file tree
Hide file tree
Showing 4 changed files with 170 additions and 9 deletions.
2 changes: 0 additions & 2 deletions src/taipy/core/_orchestrator/_orchestrator.py
Original file line number Diff line number Diff line change
Expand Up @@ -225,7 +225,6 @@ def _on_status_change(cls, job: Job):
if job.is_completed() or job.is_skipped():
cls.__unblock_jobs()
elif job.is_failed():
print(f"\nJob {job.id} failed, abandoning subsequent jobs.\n")
cls._fail_subsequent_jobs(job)

@classmethod
Expand Down Expand Up @@ -298,7 +297,6 @@ def _fail_subsequent_jobs(cls, failed_job: Job):
cls.__find_subsequent_jobs(failed_job.submit_id, set(failed_job.task.output.keys()))
)
for job in to_fail_or_abandon_jobs:
print(f"Abandoning job: {job.id}")
job.abandoned()
to_fail_or_abandon_jobs.update([failed_job])
cls.__remove_blocked_jobs(to_fail_or_abandon_jobs)
Expand Down
Loading

0 comments on commit c3f2a21

Please sign in to comment.