lavoratore sedano non si riconnette compito dopo la chiamata di tentativi()

Question

Ho un compito:

@celery.task(name='request_task',default_retry_delay=2,acks_late=True) 
    def request_task(data): 
     try: 
      if some_condition: 
       request_task.retry() 
     except Exception as e: 
      request_task.retry() 

Io uso il sedano con mediatore di MongoDB e MongoDB risultati backend abilitato.

Quando viene chiamato il metodo dell'attività retry(), né dall'istruzione condizionale né dopo aver rilevato l'eccezione, l'attività non viene ritentata.

nel terminale del lavoratore ottengo messaggio come questo:

[2012-08-10 19: 21: 54.909: INFO/MainProcess] Task request_task [badb3131-8964-41b5-90a7-245a8131e68d] riprovare : L'attività può essere ritentata

Cosa può essere che non va?

AGGIORNAMENTO: Infine, non ho risolto questa domanda e ho dovuto utilizzare il ciclo durante l'attività, quindi le mie attività non vengono mai riprovate.

Answer 1

Si consiglia di leggere la sezione su riprovare nei documenti di Celery. http://celery.readthedocs.org/en/latest/userguide/tasks.html#retrying

Sembra che per riprovare, è necessario generare un'eccezione di tentativo.

raise request_task.retry() 

Sembra che il tentativo venga gestito dalla funzione che ha decorato il compito.