From f8517d0677497216f91b4b069a58bd71523a3fc2 Mon Sep 17 00:00:00 2001 From: Ilya Mukhortov Date: Wed, 5 Mar 2025 09:07:49 +1000 Subject: [PATCH] pass --- appa/settings.py | 7 ++++++- appa/tasks.py | 5 +++-- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/appa/settings.py b/appa/settings.py index 9bba4f0..09a0d01 100644 --- a/appa/settings.py +++ b/appa/settings.py @@ -218,7 +218,12 @@ CELERYBEAT_SCHEDULE = { 'task': 'appa.tasks.check_call_requests_task', 'schedule': crontab(minute='*/5'), 'options': {'queue': CELERY_DEFAULT_QUEUE} - } + }, + 'send_daily_call_request_task': { + 'task': 'appa.tasks.send_daily_call_request_task', + 'schedule': crontab(hour='10', minute='0'), + 'options': {'queue': CELERY_DEFAULT_QUEUE} + }, } DATE_FORMAT = 'd.m.Y' diff --git a/appa/tasks.py b/appa/tasks.py index 60001a3..6c0d9b2 100644 --- a/appa/tasks.py +++ b/appa/tasks.py @@ -25,7 +25,7 @@ def send_call_request_task(self, ids=None): @app.task(bind=True, acks_late=True) -def send_daily_call_request_task(self, ids=None): +def send_daily_call_request_task(self): tomorrow = datetime.date.today() + datetime.timedelta(days=1) call_requests = CallRequest.objects.filter( date=tomorrow, @@ -82,6 +82,7 @@ def update_call_requests_task(self): @app.task(bind=True, acks_late=True) def check_call_requests_task(self): for call_request in CallRequest.objects.filter( - request_status=CallRequest.RequestStatus.SENT + request_status=CallRequest.RequestStatus.SENT, + date=datetime.date.today() ): call_api.get_record(call_request)