Fix build (#9344)

airbytehq · Jan 6, 2022 · 80695ad · 80695ad
1 parent ed46b2d
commit 80695ad
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 8 deletions.
diff --git a/...iner-orchestrator/src/main/java/io/airbyte/container_orchestrator/DbtJobOrchestrator.java b/...iner-orchestrator/src/main/java/io/airbyte/container_orchestrator/DbtJobOrchestrator.java
@@ -59,7 +59,8 @@ public void runJob() throws Exception {
             processFactory, NormalizationRunnerFactory.create(
                 workerConfigs,
                 destinationLauncherConfig.getDockerImage(),
-                processFactory)));;
+                processFactory,
+                NormalizationRunnerFactory.NORMALIZATION_VERSION)));
 
     log.info("Running dbt worker...");
     final Path jobRoot = WorkerUtils.getJobRoot(configs.getWorkspaceRoot(), jobRunConfig.getJobId(), jobRunConfig.getAttemptId());

diff --git a/...strator/src/main/java/io/airbyte/container_orchestrator/NormalizationJobOrchestrator.java b/...strator/src/main/java/io/airbyte/container_orchestrator/NormalizationJobOrchestrator.java
@@ -56,7 +56,8 @@ public void runJob() throws Exception {
         NormalizationRunnerFactory.create(
             workerConfigs,
             destinationLauncherConfig.getDockerImage(),
-            processFactory),
+            processFactory,
+            NormalizationRunnerFactory.NORMALIZATION_VERSION),
         configs.getWorkerEnvironment());
 
     log.info("Running normalization worker...");

diff --git a/...te-workers/src/main/java/io/airbyte/workers/normalization/NormalizationRunnerFactory.java b/...te-workers/src/main/java/io/airbyte/workers/normalization/NormalizationRunnerFactory.java
@@ -34,8 +34,6 @@ public class NormalizationRunnerFactory {
           .put("airbyte/destination-postgres-strict-encrypt", ImmutablePair.of(BASE_NORMALIZATION_IMAGE_NAME, DestinationType.POSTGRES))
           .put("airbyte/destination-redshift", ImmutablePair.of(BASE_NORMALIZATION_IMAGE_NAME, DestinationType.REDSHIFT))
           .put("airbyte/destination-snowflake", ImmutablePair.of("airbyte/normalization-snowflake", DestinationType.SNOWFLAKE))
-          .put("airbyte/destination-clickhouse", ImmutablePair.of("airbyte/normalization-clickhouse", DestinationType.CLICKHOUSE))
-          .put("airbyte/destination-clickhouse-strict-encrypt", ImmutablePair.of("airbyte/normalization-clickhouse", DestinationType.CLICKHOUSE))
           .build();
 
   public static NormalizationRunner create(final WorkerConfigs workerConfigs,

diff --git a/...workers/src/main/java/io/airbyte/workers/temporal/sync/DbtTransformationActivityImpl.java b/...workers/src/main/java/io/airbyte/workers/temporal/sync/DbtTransformationActivityImpl.java
@@ -111,10 +111,10 @@ private CheckedSupplier<Worker<OperatorDbtInput, Void>, Exception> getLegacyWork
         new DbtTransformationRunner(
             workerConfigs,
             jobProcessFactory, NormalizationRunnerFactory.create(
-            workerConfigs,
-            destinationLauncherConfig.getDockerImage(),
-            jobProcessFactory,
-            NormalizationRunnerFactory.NORMALIZATION_VERSION)));
+                workerConfigs,
+                destinationLauncherConfig.getDockerImage(),
+                jobProcessFactory,
+                NormalizationRunnerFactory.NORMALIZATION_VERSION)));
   }
 
   private CheckedSupplier<Worker<OperatorDbtInput, Void>, Exception> getContainerLauncherWorkerFactory(