Skip to content
Snippets Groups Projects

Added celery worker and celery beat

Merged Mohammad Torkashvand requested to merge feature/NAT-358-setup-celery into develop
All threads resolved!
2 files
+ 0
12
Compare changes
  • Side-by-side
  • Inline
Files
2
+ 0
11
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")
Loading