restore containerOrchestrator image value

airbyte-config/config-models/src/main/java/io/airbyte/config/Configs.java

@@ -671,6 +671,12 @@ public interface Configs {
 
   // Container Orchestrator
 
+  /**
+   * Define if Airbyte should use the container orchestrator. Internal-use only.
+   * Should always be set to true - otherwise causes syncs to be run on workers instead.
+   */
+  boolean getContainerOrchestratorEnabled();
+
   /**
    * Get the name of the container orchestrator secret. Internal-use only.
    */

airbyte-config/config-models/src/main/java/io/airbyte/config/EnvConfigs.java

@@ -115,6 +115,7 @@ public class EnvConfigs implements Configs {
   private static final String CONFIGS_DATABASE_INITIALIZATION_TIMEOUT_MS = "CONFIGS_DATABASE_INITIALIZATION_TIMEOUT_MS";
   private static final String JOBS_DATABASE_MINIMUM_FLYWAY_MIGRATION_VERSION = "JOBS_DATABASE_MINIMUM_FLYWAY_MIGRATION_VERSION";
   private static final String JOBS_DATABASE_INITIALIZATION_TIMEOUT_MS = "JOBS_DATABASE_INITIALIZATION_TIMEOUT_MS";
+  private static final String CONTAINER_ORCHESTRATOR_ENABLED = "CONTAINER_ORCHESTRATOR_ENABLED";
   private static final String CONTAINER_ORCHESTRATOR_SECRET_NAME = "CONTAINER_ORCHESTRATOR_SECRET_NAME";
   private static final String CONTAINER_ORCHESTRATOR_SECRET_MOUNT_PATH = "CONTAINER_ORCHESTRATOR_SECRET_MOUNT_PATH";
   private static final String CONTAINER_ORCHESTRATOR_IMAGE = "CONTAINER_ORCHESTRATOR_IMAGE";
@@ -1057,6 +1058,11 @@ public Set<Integer> getTemporalWorkerPorts() {
     return Arrays.stream(ports.split(",")).map(Integer::valueOf).collect(Collectors.toSet());
   }
 
+  @Override
+  public boolean getContainerOrchestratorEnabled() {
+    return getEnvOrDefault(CONTAINER_ORCHESTRATOR_ENABLED, false, Boolean::valueOf);
+  }
+
   @Override
   public String getContainerOrchestratorSecretName() {
     return getEnvOrDefault(CONTAINER_ORCHESTRATOR_SECRET_NAME, null);

airbyte-workers/src/main/resources/application.yml

@@ -52,6 +52,7 @@ airbyte:
     specific-resource-defaults-enabled: ${CONNECTOR_SPECIFIC_RESOURCE_DEFAULTS_ENABLED:false}
   container:
     orchestrator:
+      enabled: ${CONTAINER_ORCHESTRATOR_ENABLED:false}
       image: ${CONTAINER_ORCHESTRATOR_IMAGE:}
       java-opts: ${CONTAINER_ORCHESTRATOR_JAVA_OPTS:}
       secret-mount-path: ${CONTAINER_ORCHESTRATOR_SECRET_MOUNT_PATH:}

charts/airbyte-worker/values.yaml

@@ -347,6 +347,7 @@ secrets: {}
 #   JOB_KUBE_MAIN_CONTAINER_IMAGE_PULL_POLICY:
 
 #   # Launch a separate pod to orchestrate sync steps
+#   CONTAINER_ORCHESTRATOR_ENABLED: true
 #   CONTAINER_ORCHESTRATOR_IMAGE:
 
 #   # Open Telemetry Configuration

charts/airbyte/templates/env-configmap.yaml

@@ -64,6 +64,7 @@ data:
   WORKFLOW_FAILURE_RESTART_DELAY_SECONDS: ""
   USE_STREAM_CAPABLE_STATE: "true"
   AUTO_DETECT_SCHEMA: "false"
+  CONTAINER_ORCHESTRATOR_ENABLED: {{ .Values.worker.containerOrchestrator.enabled | quote }}
   CONTAINER_ORCHESTRATOR_IMAGE: {{ .Values.worker.containerOrchestrator.image | quote }}
   WORKERS_MICRONAUT_ENVIRONMENTS: "control-plane"
   CRON_MICRONAUT_ENVIRONMENTS: "control-plane"

charts/airbyte/values.yaml

@@ -795,7 +795,14 @@ worker:
 
   hpa:
     enabled: false
-
+  ## Container Orchestrator
+  ## enabled -- Enable or disable Orchestrator
+  ## image -- Orchestrator image
+
+  containerOrchestrator:
+    enabled: true
+    image: ""
+
 ## @section Metrics parameters
 metrics:
   enabled: false

kube/overlays/dev-integration-test/.env

@@ -74,6 +74,7 @@ JOB_KUBE_NODE_SELECTORS=
 JOB_KUBE_MAIN_CONTAINER_IMAGE_PULL_POLICY=
 
 # Launch a separate pod to orchestrate sync steps
+CONTAINER_ORCHESTRATOR_ENABLED=true
 CONTAINER_ORCHESTRATOR_IMAGE=
 
 # Cloud Storage Configuration

kube/overlays/dev/.env

@@ -76,6 +76,7 @@ JOB_KUBE_NODE_SELECTORS=
 JOB_KUBE_MAIN_CONTAINER_IMAGE_PULL_POLICY=
 
 # Launch a separate pod to orchestrate sync steps
+CONTAINER_ORCHESTRATOR_ENABLED=true
 CONTAINER_ORCHESTRATOR_IMAGE=
 
 # Cloud Storage Configuration

kube/overlays/stable-with-resource-limits/.env

@@ -76,6 +76,7 @@ JOB_KUBE_NODE_SELECTORS=
 JOB_KUBE_MAIN_CONTAINER_IMAGE_PULL_POLICY=
 
 # Launch a separate pod to orchestrate sync steps
+CONTAINER_ORCHESTRATOR_ENABLED=true
 CONTAINER_ORCHESTRATOR_IMAGE=
 
 CONNECTOR_SPECIFIC_RESOURCE_DEFAULTS_ENABLED=true

kube/overlays/stable/.env

@@ -76,6 +76,7 @@ JOB_KUBE_NODE_SELECTORS=
 JOB_KUBE_MAIN_CONTAINER_IMAGE_PULL_POLICY=
 
 # Launch a separate pod to orchestrate sync steps
+CONTAINER_ORCHESTRATOR_ENABLED=true
 CONTAINER_ORCHESTRATOR_IMAGE=
 
 # Cloud Storage Configuration

kube/resources/worker.yaml

@@ -220,6 +220,11 @@ spec:
                 secretKeyRef:
                   name: airbyte-secrets
                   key: STATE_STORAGE_MINIO_SECRET_ACCESS_KEY
+            - name: CONTAINER_ORCHESTRATOR_ENABLED
+              valueFrom:
+                configMapKeyRef:
+                  name: airbyte-env
+                  key: CONTAINER_ORCHESTRATOR_ENABLED
             - name: CONTAINER_ORCHESTRATOR_IMAGE
               valueFrom:
                 configMapKeyRef: