You need to use a non-blocking runner where p.run() returns immediately.
It returns a PipelineResult (
which provides cancel() and other operations.
On Wed, Sep 21, 2016 at 5:03 PM amir bahmanyari <amirto...@yahoo.com> wrote:
> While still running [p.run()], is there a way to terminate a pipleline p.x
> based on a condition for instance?
> I didnt see any related api like p.terminate() or similar...