我的应用程序在页面上收集了一堆电话号码.一旦用户点击提交按钮,我创建一个芹菜任务来调用每个号码并给出一个提醒消息,然后将它们重定向到一个页面,在那里他们可以看到有关该呼叫的实时更新.我正在使用Web套接字来实时更新每个呼叫的状态,并且需要同步执行任务,因为我只能从一个号码拨出.
因此,一旦第一个呼叫/任务完成,我希望下一个呼叫/任务启动.
我看了一下CELERY_ALWAYS_EAGER设置,但它刚刚完成第一次迭代并停止了.
@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')
Run Code Online (Sandbox Code Playgroud)