chore: pass secret mounts to init container for runtime secret manage…

…ment (#13524)
airbytehq · Aug 14, 2024 · 4cbb732 · 4cbb732
1 parent ddb1e63
commit 4cbb732
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/airbyte-workload-launcher/src/main/kotlin/pods/factories/ConnectorPodFactory.kt b/airbyte-workload-launcher/src/main/kotlin/pods/factories/ConnectorPodFactory.kt
@@ -69,16 +69,17 @@ class ConnectorPodFactory(
     }
 
     val connectorResourceReqs = KubePodProcess.getResourceRequirementsBuilder(connectorReqs).build()
+    val internalVolumeMounts = volumeMounts + secretVolumeMounts
 
     val init: Container =
       if (useFetchingInit) {
-        initContainerFactory.createFetching(connectorResourceReqs, volumeMounts, runtimeEnvVars)
+        initContainerFactory.createFetching(connectorResourceReqs, internalVolumeMounts, runtimeEnvVars)
       } else {
-        initContainerFactory.createWaiting(connectorResourceReqs, volumeMounts)
+        initContainerFactory.createWaiting(connectorResourceReqs, internalVolumeMounts)
       }
 
     val main: Container = buildMainContainer(connectorResourceReqs, volumeMounts, kubePodInfo.mainContainerInfo, runtimeEnvVars)
-    val sidecar: Container = buildSidecarContainer(volumeMounts + secretVolumeMounts)
+    val sidecar: Container = buildSidecarContainer(internalVolumeMounts)
 
     // TODO: We should inject the scheduler from the ENV and use this just for overrides
     val schedulerName = featureFlagClient.stringVariation(UseCustomK8sScheduler, Connection(ANONYMOUS))