diff --git a/airbyte-workers/src/test/java/io/airbyte/workers/temporal/sync/SyncWorkflowTest.java b/airbyte-workers/src/test/java/io/airbyte/workers/temporal/sync/SyncWorkflowTest.java index 837d56f8c1240..ced994bdde45c 100644 --- a/airbyte-workers/src/test/java/io/airbyte/workers/temporal/sync/SyncWorkflowTest.java +++ b/airbyte-workers/src/test/java/io/airbyte/workers/temporal/sync/SyncWorkflowTest.java @@ -403,7 +403,7 @@ void testWebhookOperation() { @Test void testSkipReplicationAfterRefreshSchema() throws JsonValidationException, ConfigNotFoundException, IOException, ApiException { - when(configFetchActivity.getStandardSync(any())).thenReturn(new StandardSync().withSourceId(UUID.randomUUID()).withStatus(Status.INACTIVE)); + when(configFetchActivity.getStandardSync(any())).thenReturn(new StandardSync().withSourceId(SOURCE_ID).withStatus(Status.INACTIVE)); StandardSyncOutput output = execute(); verifyShouldRefreshSchema(refreshSchemaActivity); verifyRefreshSchema(refreshSchemaActivity, sync);