set workspaceId on destinationCoreConfig (#22843)

airbytehq · Feb 10, 2023 · 83d26d2 · 83d26d2
1 parent f06c213
commit 83d26d2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/...yte-commons-server/src/main/java/io/airbyte/commons/server/handlers/SchedulerHandler.java b/...yte-commons-server/src/main/java/io/airbyte/commons/server/handlers/SchedulerHandler.java
@@ -241,7 +241,8 @@ public CheckConnectionRead checkDestinationConnectionFromDestinationIdForUpdate(
     final DestinationCoreConfig destinationCoreConfig = new DestinationCoreConfig()
         .destinationId(updatedDestination.getDestinationId())
         .connectionConfiguration(updatedDestination.getConfiguration())
-        .destinationDefinitionId(updatedDestination.getDestinationDefinitionId());
+        .destinationDefinitionId(updatedDestination.getDestinationDefinitionId())
+        .workspaceId(updatedDestination.getWorkspaceId());
 
     return checkDestinationConnectionFromDestinationCreate(destinationCoreConfig);
   }

diff --git a/...commons-server/src/test/java/io/airbyte/commons/server/handlers/SchedulerHandlerTest.java b/...commons-server/src/test/java/io/airbyte/commons/server/handlers/SchedulerHandlerTest.java
@@ -391,7 +391,8 @@ void testCheckDestinationConnectionFromUpdate() throws IOException, JsonValidati
     final DestinationConnection submittedDestination = new DestinationConnection()
         .withDestinationId(destination.getDestinationId())
         .withDestinationDefinitionId(destination.getDestinationDefinitionId())
-        .withConfiguration(destination.getConfiguration());
+        .withConfiguration(destination.getConfiguration())
+        .withWorkspaceId(destination.getWorkspaceId());
     when(synchronousSchedulerClient.createDestinationCheckConnectionJob(submittedDestination, DESTINATION_DOCKER_IMAGE,
         new Version(DESTINATION_PROTOCOL_VERSION), false))
             .thenReturn((SynchronousResponse<StandardCheckConnectionOutput>) jobResponse);