AVEC LE BROKER pAR DEFAUT :

from amqplib import client_0_8 as amqp
conn = amqp.Connection(host="localhost:5672", urserid="guest", password="guest", virtual_host="/", insist=False)
conn_chan = conn.channel()
conn_chan.queue_purge("execute_sequence_q")

Le souci, c'est que ça gère pas les coutdowns. Donc ça delete aps ce que je veux.
Deux solutions :
     - chercher comment passer outre ce problème des coutdowns
     - tester avec un autre broker

Théoriquement un autre broker c'est juste une ligne de plus, donc je vais tester ça en premier.


from majordome.tasks import execute_sequence as es

>>> from celery.task.control import revoke
>>> revoke('435bd2c9-cb71-41a5-af8f-60b99e7ef8ad')

Je devrais peut-être créer des groupes ou chords ou chain pour les execute_plan dans execute_sequence pour éviter le get()

res = res = es.apply_async((4,), countdown=30)
res.id, res.state, res.ready(), ...