Skip to content

Instantly share code, notes, and snippets.

@tonytan4ever
Created October 21, 2015 22:17
Show Gist options
  • Save tonytan4ever/d121451b4728eef4bee6 to your computer and use it in GitHub Desktop.
Save tonytan4ever/d121451b4728eef4bee6 to your computer and use it in GitHub Desktop.
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')
Level 5:taskflow.engines.action_engine.compiler:Compiling 'taskflow.patterns.linear_flow.Flow: flow name(len=3)'
Level 5:taskflow.engines.action_engine.compiler: Compiling '__main__.Task1==1.0'
Level 5:taskflow.engines.action_engine.compiler: Decomposed '__main__.Task1==1.0' into:
Level 5:taskflow.engines.action_engine.compiler: Graph:
Level 5:taskflow.engines.action_engine.compiler: Name: __main__.Task1
Level 5:taskflow.engines.action_engine.compiler: Type: DiGraph
Level 5:taskflow.engines.action_engine.compiler: Frozen: False
Level 5:taskflow.engines.action_engine.compiler: Density: 0.000
Level 5:taskflow.engines.action_engine.compiler: Nodes: 1
Level 5:taskflow.engines.action_engine.compiler: - __main__.Task1==1.0 ({'kind': 'task'})
Level 5:taskflow.engines.action_engine.compiler: Edges: 0
Level 5:taskflow.engines.action_engine.compiler: Cycles: 0
Level 5:taskflow.engines.action_engine.compiler: Hierarchy:
Level 5:taskflow.engines.action_engine.compiler: __main__.Task1==1.0
Level 5:taskflow.engines.action_engine.compiler: Compiling '__main__.Task3==1.0'
Level 5:taskflow.engines.action_engine.compiler: Decomposed '__main__.Task3==1.0' into:
Level 5:taskflow.engines.action_engine.compiler: Graph:
Level 5:taskflow.engines.action_engine.compiler: Name: __main__.Task3
Level 5:taskflow.engines.action_engine.compiler: Type: DiGraph
Level 5:taskflow.engines.action_engine.compiler: Frozen: False
Level 5:taskflow.engines.action_engine.compiler: Density: 0.000
Level 5:taskflow.engines.action_engine.compiler: Nodes: 1
Level 5:taskflow.engines.action_engine.compiler: - __main__.Task3==1.0 ({'kind': 'task'})
Level 5:taskflow.engines.action_engine.compiler: Edges: 0
Level 5:taskflow.engines.action_engine.compiler: Cycles: 0
Level 5:taskflow.engines.action_engine.compiler: Hierarchy:
Level 5:taskflow.engines.action_engine.compiler: __main__.Task3==1.0
Level 5:taskflow.engines.action_engine.compiler: Compiling '__main__.Task2==1.0'
Level 5:taskflow.engines.action_engine.compiler: Decomposed '__main__.Task2==1.0' into:
Level 5:taskflow.engines.action_engine.compiler: Graph:
Level 5:taskflow.engines.action_engine.compiler: Name: __main__.Task2
Level 5:taskflow.engines.action_engine.compiler: Type: DiGraph
Level 5:taskflow.engines.action_engine.compiler: Frozen: False
Level 5:taskflow.engines.action_engine.compiler: Density: 0.000
Level 5:taskflow.engines.action_engine.compiler: Nodes: 1
Level 5:taskflow.engines.action_engine.compiler: - __main__.Task2==1.0 ({'kind': 'task'})
Level 5:taskflow.engines.action_engine.compiler: Edges: 0
Level 5:taskflow.engines.action_engine.compiler: Cycles: 0
Level 5:taskflow.engines.action_engine.compiler: Hierarchy:
Level 5:taskflow.engines.action_engine.compiler: __main__.Task2==1.0
Level 5:taskflow.engines.action_engine.compiler:Decomposed 'taskflow.patterns.linear_flow.Flow: flow name(len=3)' into:
Level 5:taskflow.engines.action_engine.compiler: Graph:
Level 5:taskflow.engines.action_engine.compiler: Name: flow name
Level 5:taskflow.engines.action_engine.compiler: Type: DiGraph
Level 5:taskflow.engines.action_engine.compiler: Frozen: False
Level 5:taskflow.engines.action_engine.compiler: Density: 0.250
Level 5:taskflow.engines.action_engine.compiler: Nodes: 4
Level 5:taskflow.engines.action_engine.compiler: - __main__.Task2==1.0 ({'kind': 'task'})
Level 5:taskflow.engines.action_engine.compiler: - __main__.Task3==1.0 ({'kind': 'task'})
Level 5:taskflow.engines.action_engine.compiler: - __main__.Task1==1.0 ({'kind': 'task'})
Level 5:taskflow.engines.action_engine.compiler: - taskflow.patterns.linear_flow.Flow: flow name(len=3) ({'kind': 'flow', 'noop': True})
Level 5:taskflow.engines.action_engine.compiler: Edges: 3
Level 5:taskflow.engines.action_engine.compiler: taskflow.patterns.linear_flow.Flow: flow name(len=3) -> __main__.Task1==1.0 ({'invariant': True})
Level 5:taskflow.engines.action_engine.compiler: __main__.Task2==1.0 -> __main__.Task3==1.0 ({'invariant': True})
Level 5:taskflow.engines.action_engine.compiler: __main__.Task1==1.0 -> __main__.Task2==1.0 ({'invariant': True})
Level 5:taskflow.engines.action_engine.compiler: Cycles: 0
Level 5:taskflow.engines.action_engine.compiler: Hierarchy:
Level 5:taskflow.engines.action_engine.compiler: taskflow.patterns.linear_flow.Flow: flow name(len=3)
Level 5:taskflow.engines.action_engine.compiler: |____main__.Task1==1.0
Level 5:taskflow.engines.action_engine.compiler: |____main__.Task3==1.0
Level 5:taskflow.engines.action_engine.compiler: |____main__.Task2==1.0
Level 5:taskflow.engines.action_engine.engine:Validating scoping and argument visibility for execution graph with 4 nodes and 3 edges with density 0.250
Level 5:taskflow.storage:Looking for 'param2' <= 'param2' for atom named: __main__.Task2
Level 5:taskflow.engines.action_engine.scopes:Scope visible to '__main__.Task2==1.0' (limited by parent 'flow name' index < 2) is: ['__main__.Task1']
Level 5:taskflow.storage:Atom __main__.Task2 will have 1 potential providers of 'param2' <= 'param2'
Level 5:taskflow.storage:Looking for 'param2' <= 'param2' for atom named: __main__.Task3
Level 5:taskflow.engines.action_engine.scopes:Scope visible to '__main__.Task3==1.0' (limited by parent 'flow name' index < 1) is: ['__main__.Task1']
Level 5:taskflow.storage:Atom __main__.Task3 will have 1 potential providers of 'param2' <= 'param2'
Level 5:taskflow.storage:Looking for 'param3' <= 'param3' for atom named: __main__.Task3
Level 5:taskflow.storage:Looking for 'param4' <= 'param4' for atom named: __main__.Task3
Level 5:taskflow.storage:Atom __main__.Task3 will have 1 potential providers of 'param4' <= 'param4'
Traceback (most recent call last):
File "/Users/tony7514/projects/new_workspace/testNPlayWith/TaskFlow/input_data_provider.py", line 55, in <module>
engines.run(flow, store={'param4': 'new param5'})
File "/Users/tony7514/projects/Rackspace/taskflow/taskflow/engines/helpers.py", line 222, in run
engine.run()
File "/Users/tony7514/projects/Rackspace/taskflow/taskflow/engines/action_engine/engine.py", line 159, in run
for _state in self.run_iter():
File "/Users/tony7514/projects/Rackspace/taskflow/taskflow/engines/action_engine/engine.py", line 185, in run_iter
self.validate()
File "/Users/tony7514/bin/python27/lib/python2.7/site-packages/fasteners/lock.py", line 291, in wrapper
return f(self, *args, **kwargs)
File "/Users/tony7514/projects/Rackspace/taskflow/taskflow/engines/action_engine/engine.py", line 291, in validate
cause=last_cause)
taskflow.exceptions.MissingDependencies: 'taskflow.patterns.linear_flow.Flow: flow name(len=3)' requires ['param3'] but no other entity produces said requirements
MissingDependencies: '__main__.Task3==1.0' requires ['param3'] but no other entity produces said requirements
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment