paulin/bonobo
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Remove dispatcher as it is not a dependency, for now, and as such breaks the continuous integration.

Browse Source
This commit is contained in:
Romain Dorgueil
2017-10-22 18:08:03 +02:00
parent 3c453f0be7
commit 01a652cd05
1 changed files with 0 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
bonobo/execution/graph.py
View File

@ -5,7 +5,6 @@ from bonobo.config import create_container
from bonobo.constants import BEGIN, END from bonobo.constants import BEGIN, END
from bonobo.execution.node import NodeExecutionContext from bonobo.execution.node import NodeExecutionContext
from bonobo.execution.plugin import PluginExecutionContext from bonobo.execution.plugin import PluginExecutionContext
from whistle import EventDispatcher
class GraphExecutionContext: class GraphExecutionContext:
@ -24,14 +23,6 @@ class GraphExecutionContext:
def alive(self): def alive(self):
return any(node.alive for node in self.nodes) return any(node.alive for node in self.nodes)
@property
def dispatcher(self):
try:
return self._dispatcher
except AttributeError:
self._dispatcher = EventDispatcher()
return self._dispatcher
def __init__(self, graph, plugins=None, services=None): def __init__(self, graph, plugins=None, services=None):
self.graph = graph self.graph = graph
self.nodes = [self.create_node_execution_context_for(node) for node in self.graph] self.nodes = [self.create_node_execution_context_for(node) for node in self.graph]