From 3a95b639a53b98bc4f2d910f1099fb95fcd5fa70 Mon Sep 17 00:00:00 2001
From: Mohammad Torkashvand <mohammad.torkashvand@geant.org>
Date: Wed, 8 Nov 2023 14:52:28 +0100
Subject: [PATCH] remove unnecessary validation workflows
---
gso/schedules/resume_workflows.py | 11 -----------
gso/worker.py | 1 -
2 files changed, 12 deletions(-)
delete mode 100644 gso/schedules/resume_workflows.py
diff --git a/gso/schedules/resume_workflows.py b/gso/schedules/resume_workflows.py
deleted file mode 100644
index 2c168313..00000000
--- 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 cd0234ef..2376ac10 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",
],
)
--
GitLab