My app gathers a bunch of phone numbers on a page. Once the user hits the submit button I create a celery task to call each number and give a reminder message then redirect them to a page where they can see the live updates about the call. I am using web sockets to live update the status of each call and need the tasks to execute synchronously as I only have access to dial out from one number.
So once the first call/task is completed, I want the next one to fire off.
I took a look at CELERY_ALWAYS_EAGER settings but it just went through the first iteration and stopped.
@task def reminder(number): # CODE THAT CALLS NUMBER HERE.... def make_calls(request): for number in phone_numbers: reminder.delay(number) return redirect('live_call_updates')
Advertisement
Answer
if you want to fire each call one after another, why dont you wrap all the calls in one task
@task def make_a_lot_of_calls(numbers): for num in numbers: # Assuming that reminder blocks till the call finishes reminder(number) def make_calls(request): make_a_lot_of_calls.delay(phone_numers) return redirect('live_call_updates')