PipelineRunner
constructor(reconciler: StateReconciler, store: StateStore, pipelines: List<DataFlowPipeline>, inputStreams: ConnectorInputStreams, @Named(value = "pipelineRunnerScope") pipelineScope: CoroutineScope, @Named(value = "aggregationDispatcher") aggregationDispatcher: CoroutineDispatcher)