Pipeline Execution Manager with Streaming