File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed
sentry_sdk/integrations/celery Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change 99from sentry_sdk .integrations import _check_minimum_version , Integration , DidNotEnable
1010from sentry_sdk .integrations .celery .beat import (
1111 _patch_beat_apply_entry ,
12- _patch_redbeat_maybe_due ,
12+ _patch_redbeat_apply_async ,
1313 _setup_celery_beat_signals ,
1414)
1515from sentry_sdk .integrations .celery .utils import _now_seconds_since_epoch
@@ -73,7 +73,7 @@ def __init__(
7373 self .exclude_beat_tasks = exclude_beat_tasks
7474
7575 _patch_beat_apply_entry ()
76- _patch_redbeat_maybe_due ()
76+ _patch_redbeat_apply_async ()
7777 _setup_celery_beat_signals (monitor_beat_tasks )
7878
7979 @staticmethod
Original file line number Diff line number Diff line change @@ -202,12 +202,12 @@ def _patch_beat_apply_entry():
202202 Scheduler .apply_entry = _wrap_beat_scheduler (Scheduler .apply_entry )
203203
204204
205- def _patch_redbeat_maybe_due ():
205+ def _patch_redbeat_apply_async ():
206206 # type: () -> None
207207 if RedBeatScheduler is None :
208208 return
209209
210- RedBeatScheduler .maybe_due = _wrap_beat_scheduler (RedBeatScheduler .maybe_due )
210+ RedBeatScheduler .apply_async = _wrap_beat_scheduler (RedBeatScheduler .apply_async )
211211
212212
213213def _setup_celery_beat_signals (monitor_beat_tasks ):
You can’t perform that action at this time.
0 commit comments