bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.config/DispatcherBeanFactory/pipelineRunnerDispatcher

pipelineRunnerDispatcher

@Named(value = "pipelineRunnerDispatcher")

@Singleton

fun pipelineRunnerDispatcher(): CoroutineDispatcher(source)

@Named(value = "pipelineRunnerScope")

@Singleton

fun pipelineRunnerDispatcher(@Named(value = "pipelineRunnerDispatcher") dispatcher: CoroutineDispatcher): CoroutineScope(source)