diff --git a/h_periodic/h_beat.py b/h_periodic/h_beat.py index 8159c78..69fe0d8 100644 --- a/h_periodic/h_beat.py +++ b/h_periodic/h_beat.py @@ -5,6 +5,7 @@ from os import environ from celery import Celery +from celery.schedules import crontab from h_periodic._util import asbool @@ -51,6 +52,12 @@ "schedule": timedelta(minutes=1), "kwargs": {"limit": 400}, }, + "fill-annotations-pk": { + "options": {"expires": 30}, + "task": "h.tasks.annotations.fill_pk_and_user_id", + "schedule": crontab(hour="*,9-14", minute=50), + "kwargs": {"batch_size": 1000}, + }, "report-sync-annotations-queue-length": { "options": {"expires": 30}, "task": "h.tasks.indexer.report_job_queue_metrics",