remove switch statement for ab protocol (#678)

airbytehq · Oct 22, 2020 · e75aa1e · e75aa1e
1 parent c8b75e9
commit e75aa1e
Showing 1 changed file with 1 addition and 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
@@ -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) {