kontakt
/
shiftregister
2
0
Fork 0
Code

add msg send retry after delay

This commit is contained in:
Andreas (@xAndy) Zimmermann 2022-05-10 16:46:42 +02:00
parent ea6f7d2849
commit ea4ad94780
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
shiftregister/app/tasks.py
View File

@ -41,11 +41,20 @@ def send_messages():
# those messages will be picked up by the cron send later # those messages will be picked up by the cron send later
# once we have decided to continue sending messages # once we have decided to continue sending messages
@shared_task @shared_task
def send_message(msgid): def send_message(msgid, is_retry=False):
if not global_preferences["helper__send_sms"]: if not global_preferences["helper__send_sms"]:
return return
with transaction.atomic(): with transaction.atomic():
msg = Message.objects.select_for_update().get(pk=msgid) msgs = Message.objects.select_for_update().filter(pk=msgid)[:1]
if not msgs:
if not is_retry:
print("message not found, retrying")
send_message.apply_async((msgid, True), countdown=0.2)
return
else:
print(f"message {msgid} not found in retry, giving up")
return
msg = msgs[0]
if msg.sent_at: if msg.sent_at:
return return
send(msg) send(msg)