Kereviz, belirli görev adı için tüm görevler için görev durumu nasıl edinilir?

Question

celery içinde, belirli bir görev adı için tüm görevler için görev durumunu almak istiyorum. Bunun için aşağıdaki kod çalıştı.

import celery.events.state 

# Celery status instance. 
stat = celery.events.state.State() 

# task_by_type will return list of tasks. 
query = stat.tasks_by_type("my_task_name") 

# Print tasks. 
print query 

Şimdi bu kodda boş liste alıyorum.

Answer 1

Bu, yerel olarak desteklenmez. Arka uca (Mongo, Redis, vb.) Bağlı olarak, bir kuyruğun içeriklerini inceleyebilir ve içinde ne olduğunu öğrenebilirsiniz. Yapsanız bile, şu anda devam eden öğeleri kaçırırsınız. sözü

, kendin yönetmek olabilir:

result = mytask.delay(...) 
my_datastore.save("mytask", result.id) 
... 
for id in my_datastore.find(task="mytask"): 
    res = AsyncResult(id) 
    print res.state