diff --git a/airbyte-workload-launcher/src/main/kotlin/config/ContainerConfigBeanFactory.kt b/airbyte-workload-launcher/src/main/kotlin/config/ContainerConfigBeanFactory.kt index 0919d4a59da..d87b7e2febd 100644 --- a/airbyte-workload-launcher/src/main/kotlin/config/ContainerConfigBeanFactory.kt +++ b/airbyte-workload-launcher/src/main/kotlin/config/ContainerConfigBeanFactory.kt @@ -238,6 +238,15 @@ class ContainerConfigBeanFactory { } } + @Singleton + @Named("replicationImagePullSecrets") + fun replicationImagePullSecrets( + @Named("replicationWorkerConfigs") workerConfigs: WorkerConfigs, + ): List { + return workerConfigs.jobImagePullSecrets + .map { imagePullSecret -> LocalObjectReference(imagePullSecret) } + } + @Singleton @Named("checkImagePullSecrets") fun checkImagePullSecrets( diff --git a/airbyte-workload-launcher/src/main/kotlin/pods/factories/OrchestratorPodFactory.kt b/airbyte-workload-launcher/src/main/kotlin/pods/factories/OrchestratorPodFactory.kt index 1220814facf..71f753e0e7e 100644 --- a/airbyte-workload-launcher/src/main/kotlin/pods/factories/OrchestratorPodFactory.kt +++ b/airbyte-workload-launcher/src/main/kotlin/pods/factories/OrchestratorPodFactory.kt @@ -34,7 +34,7 @@ class OrchestratorPodFactory( private val orchestratorEnvSingleton: OrchestratorEnvSingleton, @Value("\${airbyte.worker.job.kube.serviceAccount}") private val serviceAccount: String?, @Named("orchestratorContainerPorts") private val containerPorts: List, - @Named("discoverImagePullSecrets") private val imagePullSecrets: List, + @Named("replicationImagePullSecrets") private val imagePullSecrets: List, private val volumeFactory: VolumeFactory, private val initContainerFactory: InitContainerFactory, ) {