diff --git a/gso/schedules/resume_workflows.py b/gso/schedules/resume_workflows.py deleted file mode 100644 index 2c168313ffeda2c87d709e4411805971bf29bd34..0000000000000000000000000000000000000000 --- a/gso/schedules/resume_workflows.py +++ /dev/null @@ -1,11 +0,0 @@ -from orchestrator.services.processes import start_process - -from gso.schedules.scheduling import scheduler -from gso.worker import celery - - -@celery.task -@scheduler(name="Resume workflows", hour="*/1") -def run_resume_workflows() -> None: - """Resume all workflows that are stuck on tasks with the status 'waiting'.""" - start_process("task_resume_workflows") diff --git a/gso/worker.py b/gso/worker.py index cd0234ef92c603f1ce296c7b31f91ccdf98176af..2376ac1019ce703aee840e85c1f1c6db6716446d 100644 --- a/gso/worker.py +++ b/gso/worker.py @@ -18,7 +18,6 @@ celery = OrchestratorCelery( include=[ "gso.schedules.task_vacuum", "gso.schedules.validate_products", - "gso.schedules.resume_workflows", "gso.schedules.validate_subscriptions", ], )