streaming pipeline with a mutable configuration - View it on GitHub