Graceful termination of pipeline at runtime

[amir bahmanyari]

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...ThanksAmir-