diff --git a/h_periodic/h_beat.py b/h_periodic/h_beat.py index 5270071..8159c78 100644 --- a/h_periodic/h_beat.py +++ b/h_periodic/h_beat.py @@ -5,7 +5,6 @@ from os import environ from celery import Celery -from celery.schedules import crontab from h_periodic._util import asbool @@ -17,9 +16,6 @@ print("h_beat disabled by DISABLE_H_BEAT environment variable") sys.exit() -SLIM_TASK_SINCE = "2018-04-01" -SLIM_TASK_UNTIL = "2020-03-30" - celery = Celery("h") celery.conf.update( beat_schedule_filename="h-celerybeat-schedule", @@ -55,26 +51,6 @@ "schedule": timedelta(minutes=1), "kwargs": {"limit": 400}, }, - "fill-annotation-slim-first-batch": { - "options": {"expires": 30}, - "task": "h.tasks.annotations.fill_annotation_slim", - "schedule": crontab(hour="7", minute="*/2"), - "kwargs": { - "batch_size": 250, - "since": SLIM_TASK_SINCE, - "until": SLIM_TASK_UNTIL, - }, - }, - "fill-annotation-slim": { - "options": {"expires": 30}, - "task": "h.tasks.annotations.fill_annotation_slim", - "schedule": crontab(hour="8-15", minute="*/2"), - "kwargs": { - "batch_size": 3000, - "since": SLIM_TASK_SINCE, - "until": SLIM_TASK_UNTIL, - }, - }, "report-sync-annotations-queue-length": { "options": {"expires": 30}, "task": "h.tasks.indexer.report_job_queue_metrics",