mirror of
https://github.com/langgenius/dify.git
synced 2026-11-11 05:41:09 +08:00
非法操作andautofix-ci[bot]
ce26b22970
Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
12 lines
427 B
Python
12 lines
427 B
Python
"""Execute one schedule through the injected schedule application service."""
|
|
|
|
from celery import shared_task
|
|
|
|
from extensions.ext_application_services import application_services
|
|
|
|
|
|
@shared_task(queue="schedule_executor")
|
|
def run_schedule_trigger(schedule_id: str) -> None:
|
|
# Schedules repeat at their next interval; preserve the existing no-retry policy.
|
|
application_services().triggers.schedules.execute(schedule_id)
|