Files
dify/api/schedule/workflow_schedule_task.py
非法操作andautofix-ci[bot] ce26b22970 refactor(api): isolate trigger execution lifecycle (#45950)
Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
2026-11-10 08:17:39 +00:00

11 lines
299 B
Python

"""Celery beat entry point for due workflow schedule polling."""
from celery import shared_task
from extensions.ext_application_services import application_services
@shared_task(queue="schedule_poller")
def poll_workflow_schedules() -> None:
application_services().triggers.schedules.poll()