Blame view

src/golden_commands_and_notes 981 Bytes
77816f10   haribo   Workflow implemen...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
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.


77816f10   haribo   Workflow implemen...
16
17
18
19
20
>>> 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()

bb45cd4a   haribo   Date: 25/05/2016
21
22
23
from majordome.tasks import execute_sequence as es

res = es.apply_async((4,), countdown=30)
7c87794b   haribo   Date: 20/05/2016
24
25
res.id, res.state, res.ready(), ...

94082e77   haribo   Date: 03/06/2016
26
pm dumpdata --indent=4 pyrosapp auth.User > fixtures/initial_fixture.json