fix config type switching (airbytehq#125)

* fix config type switching * fix formatting
shipyardapp · Aug 28, 2020 · 5d696f0 · 5d696f0
1 parent 8396668
commit 5d696f0
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/dataline-scheduler/src/main/java/io/dataline/scheduler/WorkerRunner.java b/dataline-scheduler/src/main/java/io/dataline/scheduler/WorkerRunner.java
@@ -86,6 +86,7 @@ public void run() {
                     job.getConfig().getDiscoverSchema().getDockerImage()),
                 connectionPool)
             .run();
+        break;
       case SYNC:
         final StandardSyncInput syncInput = getSyncInput(job.getConfig().getSync());
         new WorkerRun<>(
@@ -100,6 +101,9 @@ public void run() {
                     new SingerTargetFactory(job.getConfig().getSync().getDestinationDockerImage())),
                 connectionPool)
             .run();
+        break;
+      default:
+        throw new RuntimeException("Unexpected config type: " + job.getConfig().getConfigType());
     }
   }