from pipeline.engine import PipelineEngine def on_push_event(project, nodes): engine = PipelineEngine(nodes) return engine.run(project)