LoadPipelineStepTaskFactory
constructor(@Named(value = "batchStateUpdateQueue") batchUpdateQueue: QueueWriter<BatchUpdate>, @Named(value = "dataChannelInputFlows") inputFlows: Array<Flow<PipelineInputEvent>>, flushStrategy: PipelineFlushStrategy)