Python, Bonobo, Etl, Python Programming, Data Pipeline.
node svc.print_function() def get_graph(): graph = bonobo.Graph() # Add the node to the graph and inject the service graph.add_chain(my_node, _input=None, _output=None, services=[MyService({'foo': 'bar'})]) return graph if __name__ == '__main__': bonobo.run(get_graph()) In this example, I have