pipeline.run() api implemented