Skip to content
Snippets Groups Projects
Commit 3a95b639 authored by Mohammad Torkashvand's avatar Mohammad Torkashvand
Browse files

remove unnecessary validation workflows

parent 7e3cbc67
Branches
Tags
1 merge request!101Added celery worker and celery beat
Pipeline #84474 passed
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")
......@@ -18,7 +18,6 @@ celery = OrchestratorCelery(
include=[
"gso.schedules.task_vacuum",
"gso.schedules.validate_products",
"gso.schedules.resume_workflows",
"gso.schedules.validate_subscriptions",
],
)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment