scheduler builds

airbytehq · Nov 18, 2020 · 00e9dbd · 00e9dbd
1 parent 41a18ff
commit 00e9dbd
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 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
@@ -164,7 +164,7 @@ private static StandardSyncInput getSyncInput(JobSyncConfig config) {
         .withSourceConnection(config.getSourceConnection())
         .withDestinationConnection(config.getDestinationConnection())
         .withConnectionId(config.getStandardSync().getConnectionId())
-        .withCatalog(AirbyteProtocolConverters.toCatalog(config.getStandardSync().getSchema()))
+        .withCatalog(AirbyteProtocolConverters.toConfiguredCatalog(config.getStandardSync().getSchema()))
         .withSyncMode(config.getStandardSync().getSyncMode())
         .withState(config.getState());
   }

diff --git a/airbyte-scheduler/src/test/java/io/airbyte/scheduler/WorkerRunFactoryTest.java b/airbyte-scheduler/src/test/java/io/airbyte/scheduler/WorkerRunFactoryTest.java
@@ -119,7 +119,7 @@ void testSync() {
     StandardSyncInput expectedInput = new StandardSyncInput()
         .withSourceConnection(job.getConfig().getSync().getSourceConnection())
         .withDestinationConnection(job.getConfig().getSync().getDestinationConnection())
-        .withCatalog(AirbyteProtocolConverters.toCatalog(job.getConfig().getSync().getStandardSync().getSchema()))
+        .withCatalog(AirbyteProtocolConverters.toConfiguredCatalog(job.getConfig().getSync().getStandardSync().getSchema()))
         .withConnectionId(job.getConfig().getSync().getStandardSync().getConnectionId())
         .withSyncMode(job.getConfig().getSync().getStandardSync().getSyncMode())
         .withState(job.getConfig().getSync().getState());