clean

airbytehq · Mar 3, 2021 · 418e9ce · 418e9ce
1 parent e5d832d
commit 418e9ce
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 38 deletions.
diff --git a/airbyte-scheduler/src/main/java/io/airbyte/scheduler/worker_run/BaseWorkerRunFactory.java b/airbyte-scheduler/src/main/java/io/airbyte/scheduler/worker_run/BaseWorkerRunFactory.java
@@ -26,6 +26,7 @@
 
 import io.airbyte.config.JobOutput;
 import io.airbyte.workers.Worker;
+import io.airbyte.workers.process.AirbyteIntegrationLauncher;
 import io.airbyte.workers.process.IntegrationLauncher;
 import io.airbyte.workers.process.ProcessBuilderFactory;
 import java.io.Serializable;
@@ -44,7 +45,7 @@ public abstract class BaseWorkerRunFactory<T extends Serializable> implements Wo
   final WorkerRunCreator workerRunCreator;
 
   public BaseWorkerRunFactory() {
-    this(WorkerRunFactoryUtils::createLauncher, WorkerRun::new);
+    this(AirbyteIntegrationLauncher::new, WorkerRun::new);
   }
 
   BaseWorkerRunFactory(IntegrationLauncherFactory integrationLauncherFactory, WorkerRunCreator workerRunCreator) {

diff --git a/airbyte-scheduler/src/main/java/io/airbyte/scheduler/worker_run/WorkerRunFactoryUtils.java b/airbyte-scheduler/src/main/java/io/airbyte/scheduler/worker_run/WorkerRunFactoryUtils.java