Skip to content

Commit

Permalink
Can now also restart failed started jobs by setting the restart_faile…
Browse files Browse the repository at this point in the history
…d=True
  • Loading branch information
GriffinBabe committed Jul 3, 2024
1 parent de844fc commit 3a35502
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/openeo_gfmap/manager/job_manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -164,7 +164,7 @@ def _resume_postjob_actions(self, df: pd.DataFrame):

def _restart_failed_jobs(self, df: pd.DataFrame):
"""Sets-up failed jobs as "not_started" as they will be restarted by the manager."""
failed_tasks = df[df.status == "error"]
failed_tasks = df[df.status.isin(["error", "start_failed"])]
not_started_tasks = df[df.status == "not_started"]
_log.info(
f"Resetting {len(failed_tasks)} failed jobs to 'not_started'. {len(not_started_tasks)} jobs are already 'not_started'."
Expand Down

0 comments on commit 3a35502

Please sign in to comment.