bulk-cdk-toolkit-load-dlq/io.airbyte.cdk.load.write.dlq/DlqPipelineFactoryFactory/dlqPipelineFactory

dlqPipelineFactory

@Singleton
fun dlqPipelineFactory(@Named(value = "dlqInputQueue") dlqInputQueue: PartitionedQueue<PipelineEvent<StreamKey, DestinationRecordRaw>>, @Named(value = "dlqPipelineSteps") dlqPipelineSteps: List<LoadPipelineStep>, pipelineStepTaskFactory: LoadPipelineStepTaskFactory, objectLoader: ObjectLoader): DlqPipelineFactory

The end goal of this file.