From e75aa1e62e453f5b089d0172881f8ce6614a8d57 Mon Sep 17 00:00:00 2001 From: Charles Date: Wed, 21 Oct 2020 18:38:00 -0700 Subject: [PATCH] remove switch statement for ab protocol (#678) --- .../main/java/io/airbyte/scheduler/WorkerRunFactory.java | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/airbyte-scheduler/src/main/java/io/airbyte/scheduler/WorkerRunFactory.java b/airbyte-scheduler/src/main/java/io/airbyte/scheduler/WorkerRunFactory.java index b62d884e2b4b..c27bb9b45eaf 100644 --- a/airbyte-scheduler/src/main/java/io/airbyte/scheduler/WorkerRunFactory.java +++ b/airbyte-scheduler/src/main/java/io/airbyte/scheduler/WorkerRunFactory.java @@ -41,7 +41,6 @@ import io.airbyte.workers.process.AirbyteIntegrationLauncher; import io.airbyte.workers.process.IntegrationLauncher; import io.airbyte.workers.process.ProcessBuilderFactory; -import io.airbyte.workers.process.SingerIntegrationLauncher; import io.airbyte.workers.protocols.airbyte.AirbyteMessageTracker; import io.airbyte.workers.protocols.airbyte.DefaultAirbyteDestination; import io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource; @@ -143,11 +142,7 @@ private WorkerRun createSyncWorker(JobSyncConfig config, Path jobRoot) { } private IntegrationLauncher createLauncher(final String image) { - return isAirbyteProtocol(image) ? new AirbyteIntegrationLauncher(image, pbf) : new SingerIntegrationLauncher(image, pbf); - } - - private boolean isAirbyteProtocol(final String image) { - return image != null && image.contains("abprotocol"); + return new AirbyteIntegrationLauncher(image, pbf); } private static StandardCheckConnectionInput getCheckConnectionInput(JobCheckConnectionConfig config) {