Skip to content

Commit

Permalink
Stop filling up the slim table until we find an alternative approach
Browse files Browse the repository at this point in the history
  • Loading branch information
marcospri committed Nov 29, 2023
1 parent 4cac15f commit 64bfacc
Showing 1 changed file with 0 additions and 24 deletions.
24 changes: 0 additions & 24 deletions h_periodic/h_beat.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
from os import environ

from celery import Celery
from celery.schedules import crontab

from h_periodic._util import asbool

Expand All @@ -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",
Expand Down Expand Up @@ -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",
Expand Down

0 comments on commit 64bfacc

Please sign in to comment.