apunkt/SurfSense
1
0
Fork 0
mirror of https://github.com/MODSetter/SurfSense.git synced 2026-05-31 19:45:15 +02:00
Code Issues Projects Releases Packages Wiki Activity

feat(automations): wire trigger selectors and beat into celery

Browse source
This commit is contained in:
CREDO23 2026-05-29 17:49:12 +02:00
parent b1642993ba
commit f356e304e8
1 changed files with 11 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

22
surfsense_backend/app/celery_app.py
View file

@ -189,7 +189,8 @@ celery_app = Celery(
"app.tasks.celery_tasks.stale_notification_cleanup_task", "app.tasks.celery_tasks.stale_notification_cleanup_task",
"app.tasks.celery_tasks.stripe_reconciliation_task", "app.tasks.celery_tasks.stripe_reconciliation_task",
"app.automations.tasks.execute_run", "app.automations.tasks.execute_run",
"app.automations.tasks.schedule_tick", "app.automations.triggers.builtin.schedule.selector",
"app.automations.triggers.builtin.event.selector",
], ],
) )
@ -247,6 +248,12 @@ celery_app.conf.update(
}, },
) )
# Imported late (after celery_app is built) to keep the automations triggers
# package out of this module's top-level import graph.
from app.automations.triggers.builtin.schedule.source import ( # noqa: E402
BEAT_SCHEDULE as SCHEDULE_BEAT_SCHEDULE,
)
# Configure Celery Beat schedule # Configure Celery Beat schedule
# This uses a meta-scheduler pattern: instead of creating individual Beat schedules # This uses a meta-scheduler pattern: instead of creating individual Beat schedules
# for each connector, we have ONE schedule that checks the database at the configured interval # for each connector, we have ONE schedule that checks the database at the configured interval
@ -284,14 +291,7 @@ celery_app.conf.beat_schedule = {
"expires": 60, "expires": 60,
}, },
}, },
# Fire due automation schedule triggers. Ticks every minute; per-row cron # Fire due automation schedule triggers (Beat entry owned by the schedule
# math is precomputed (next_fire_at column) so the tick is an indexed # trigger; see app.automations.triggers.builtin.schedule.source).
# lookup, not N cron evaluations. **SCHEDULE_BEAT_SCHEDULE,
"automation-schedule-tick": {
"task": "automation_schedule_tick",
"schedule": crontab(minute="*"),
"options": {
"expires": 50,
},
},
} }