Paste #444646
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 | $ python test.py
DEBUG:taskflow.engines.helpers:Looking for 'default' engine driver in 'taskflow.engines'
DEBUG:stevedore.extension:found extension EntryPoint.parse('default = taskflow.engines.action_engine.engine:SerialActionEngine')
DEBUG:stevedore.extension:found extension EntryPoint.parse('serial = taskflow.engines.action_engine.engine:SerialActionEngine')
DEBUG:stevedore.extension:found extension EntryPoint.parse('workers = taskflow.engines.worker_based.engine:WorkerBasedActionEngine')
DEBUG:stevedore.extension:found extension EntryPoint.parse('worker-based = taskflow.engines.worker_based.engine:WorkerBasedActionEngine')
DEBUG:stevedore.extension:found extension EntryPoint.parse('parallel = taskflow.engines.action_engine.engine:ParallelActionEngine')
Name: work
Type: DiGraph
Frozen: True
Nodes: 4
- __main__.UserCreator==1.0
- __main__.DataSourceUser==1.0
- __main__.DataSourceGroup==1.0
- __main__.GroupCreator==1.0
Edges: 3
__main__.DataSourceGroup==1.0 -> __main__.GroupCreator==1.0 ({'reasons': frozenset(['group_id'])})
__main__.DataSourceUser==1.0 -> __main__.UserCreator==1.0 ({'reasons': frozenset(['user_id'])})
__main__.DataSourceUser==1.0 -> __main__.GroupCreator==1.0 ({'reasons': frozenset(['user_id'])})
Density: 0.250
Cycles: 0
DEBUG:taskflow.listeners.logging:Flow 'work' (7653fa11-68f9-4b5d-bcf0-6fdebcfbce25) transitioned into state 'RUNNING' from state 'PENDING'
DEBUG:taskflow.listeners.logging:Task '__main__.DataSourceUser' (80d91b54-e2e3-4d29-9bb0-77f56bd93ae4) transitioned into state 'RUNNING' from state 'PENDING'
DEBUG:taskflow.listeners.logging:Task '__main__.DataSourceGroup' (211aad71-515e-48ac-a08a-3b2b3165c708) transitioned into state 'RUNNING' from state 'PENDING'
DEBUG:taskflow.listeners.logging:Task '__main__.DataSourceUser' (80d91b54-e2e3-4d29-9bb0-77f56bd93ae4) transitioned into state 'SUCCESS' from state 'RUNNING' with result '{'user_id': 'a'}'
DEBUG:taskflow.listeners.logging:Task '__main__.DataSourceGroup' (211aad71-515e-48ac-a08a-3b2b3165c708) transitioned into state 'SUCCESS' from state 'RUNNING' with result '{'group_id': 'c'}'
DEBUG:taskflow.listeners.logging:Task '__main__.UserCreator' (2c7f0557-9d5d-4ff8-8759-2c2b012bd4fb) transitioned into state 'RUNNING' from state 'PENDING'
Creating user a
DEBUG:taskflow.listeners.logging:Task '__main__.GroupCreator' (6ba6a36d-193c-4c21-9f1f-e0e8e7f5a960) transitioned into state 'RUNNING' from state 'PENDING'
Creating user group c:a
DEBUG:taskflow.listeners.logging:Task '__main__.UserCreator' (2c7f0557-9d5d-4ff8-8759-2c2b012bd4fb) transitioned into state 'SUCCESS' from state 'RUNNING' with result 'None'
DEBUG:taskflow.listeners.logging:Task '__main__.GroupCreator' (6ba6a36d-193c-4c21-9f1f-e0e8e7f5a960) transitioned into state 'SUCCESS' from state 'RUNNING' with result 'None'
DEBUG:taskflow.listeners.logging:Flow 'work' (7653fa11-68f9-4b5d-bcf0-6fdebcfbce25) transitioned into state 'SUCCESS' from state 'RUNNING'
|