Sedano - Completa compito, ma non restituisce il risultato

Question

Ho appena installato sedano e sto cercando di seguire il tutorial:

Ho un file chiamato tasks.py con il seguente codice:

from celery import Celery 

app = Celery('tasks', backend='amqp', broker='amqp://') 

@app.task 
def add(x, y): 
    return x + y 

I RabitMQ installato (non ho configurato con esso dal momento che il tutorial non menzionava nulla di quel genere).

ho eseguire il server lavoratore sedano come segue:

celery -A tasks worker --loglevel=info 

Sembra avvia normalmente (qui è l'output: http://i.imgur.com/qnoNCzJ.png)

Poi ho eseguito uno script con il seguente:

from tasks import add 
from time import sleep 

result = add.delay(2,2) 

while not result.ready(): 
    sleep(10) 

Quando controllo lo result.ready() ottengo sempre False (quindi il ciclo while sopra viene eseguito per sempre). Nei registri di Celery, tuttavia, tutto sembra a posto:

[2014-10-30 00:58:46,673: INFO/MainProcess] Received task: tasks.add[2bc4ceba-1319-49ce-962d-1ed0a424a2ce] 
[2014-10-30 00:58:46,674: INFO/MainProcess] Task tasks.add[2bc4ceba-1319-49ce-962d-1ed0a424a2ce] succeeded in 0.000999927520752s: 4 

Quindi il compito è stato ripreso e ha esito positivo. Eppure, result.ready() è ancora Falso. Qualche idea sul perché questo potrebbe essere? Sono su Windows 7 e sto usando RabbitMQ. Grazie in anticipo.

Answer 1

Celery deve avere il backend risultato abilitato. Vedi

http://celery.readthedocs.org/en/latest/configuration.html#celery-result-backend

Vedere anche http://celery.readthedocs.org/en/latest/getting-started/first-steps-with-celery.html#calling-the-task.

Answer 2

Va bene, ho creato una chiara VM con sedano fresco installare, impostare i seguenti file:

tasks.py:

from celery import Celery 

app = Celery('tasks', backend='amqp', broker='amqp://') 

@app.task 
def add(x, y): 
    return x + y 

E runme.py

from tasks import add 
import time 

result = add.delay(1,2) 
while not result.ready(): 
    time.sleep(1) 

print(result.get()) 

Quindi ho impostato il sedano con:

celery -A tasks worker --loglevel=info 

e successivamente ho eseguito il runme.py che dà risultato atteso:

[puciek@somewhere tmp]# python3.3 runme.py 
3 

Quindi chiaramente il problema è all'interno del vostro setup, molto probabilmente da qualche parte nel montaggio di coniglio-mq, quindi vi consiglio di reinstallarlo con l'ultima versione stabile da fonti , che è quello che sto usando, e come puoi vedere - funziona perfettamente.

Aggiornamento:

In realtà, il problema può essere così banale come si possa immaginare - siete sicuri che si sta utilizzando la stessa versione per la marcia di sedano, e l'esecuzione di vostro consumatore? Sono riuscito a riprodurlo, dove ho eseguito sedery su Python3.3 e successivamente ho eseguito runme.py con la versione 2.7. Il risultato è stato come hai descritto.

Answer 3

dovrebbe risolvere il tuo problema

ignore_result=False