Merge pull request #224 from knkski/naive-execution-services

Adding services to naive execution strategy
This commit is contained in:
Romain Dorgueil
2017-11-14 08:33:42 +01:00
committed by GitHub

View File

@ -4,8 +4,8 @@ from bonobo.structs.bags import Bag
class NaiveStrategy(Strategy):
def execute(self, graph, *args, plugins=None, **kwargs):
context = self.create_graph_execution_context(graph, plugins=plugins)
def execute(self, graph, *args, plugins=None, services=None, **kwargs):
context = self.create_graph_execution_context(graph, plugins=plugins, services=services)
context.write(BEGIN, Bag(), END)
# TODO: how to run plugins in "naive" mode ?