Trudność z selerem: obiekt funkcji nie ma właściwości "opóźnienia"

Question

Ostatnio przeżywałem rozwój oprogramowania i odniosłem sukces w zakresie gięcia selera do mojej woli.

Użyłem go z powodzeniem do wysyłania e-maili i właśnie próbowałem użyć prawie dokładnie tego samego kodu (po ponownym uruchomieniu wszystkich procesów itp.), Aby wysłać sms przez Twilio.

jednak wciąż otrzymuję następujący problem:

File "/Users/Rob/Dropbox/Python/secTrial/views.py", line 115, in send_sms 
send_sms.delay(recipients, form.text.data) 
AttributeError: 'function' object has no attribute 'delay' 

Mój kod wygląda następująco:

@celery.task 
def send_email(subject, sender, recipients, text_body): 
    msg = Message(subject, sender=sender) 
    for email in recipients: 
     msg.add_recipient(email) 
    msg.body = text_body 
    mail.send(msg) 

@celery.task 
def send_sms(recipients, text_body): 
    for number in recipients: 
     print number 
     num = '+61' + str(number) 
     print num 
     msg = text_body + 'this message to' + num 
     client.messages.create(to=num, from_="+14804054823", body=msg) 

send_email.delay gdy wywołana z moim views.py działa perfekcyjnie, jednak send_sms.delay zawiedzie za każdym razem z powyższym błędem.

Każda pomoc dotycząca rozwiązywania problemów jest mile widziana.

- Zgodnie z wnioskiem:

@app.route('/send_mail', methods=['GET', 'POST']) 
@roles_accepted('Admin') 
def send_mail(): 
    form = SendMailForm(request.form) 
    if request.method == 'POST': 
     if form.validate_on_submit(): 
      emails = db.session.query(User.email).all() 
      list_emails = list(zip(*emails)[0]) 
      send_email.delay('Subject', 'sender@example.com', list_emails, form.text.data) 
    return render_template('send_generic.html', form=form) 

@app.route('/send_sms', methods=['GET', 'POST']) 
@roles_accepted('Admin') 
def send_sms(): 
    form = SendMailForm(request.form) 
    if request.method == 'POST': 
     if form.validate_on_submit(): 
      recipients = db.session.query(User.mobile).all() 
      list_recipients = filter(None, list(zip(*recipients)[0])) 
      send_sms.delay(list_recipients, form.text.data) 
    return render_template('send_generic.html', form=form, send_sms=send_sms) 

Moja send_sms seler urządzone funkcja jest wyświetlany jako zarejestrowanego zadania:

i config Ja po prostu używając gości: RabbitMQ

CELERY_BROKER_URL = 'amqp://guest@localhost//' 
CELERY_RESULT_BACKEND = 'amqp://guest@localhost//' 

Answer 1

Nazwa widoku send_sms powoduje konflikty z nazwą zadania selera. Nazwa send_sms odwołuje się do widoku, a nie do zadania, gdy jest używany w module zawierającym widok.

Użyj innej nazwy, aby uniknąć nadpisywania.