cdk-java: reorganize the DestinationAccptanceTest to split out the ac…

…tual tests from all the util methods
airbytehq · Oct 9, 2024 · 48a9e9e · 48a9e9e
1 parent 78d6139
commit 48a9e9e
Show file tree

Hide file tree

Showing 3 changed files with 1,190 additions and 1,113 deletions.
diff --git a/...ain/kotlin/io/airbyte/cdk/integrations/destination/async/state/GlobalAsyncStateManager.kt b/...ain/kotlin/io/airbyte/cdk/integrations/destination/async/state/GlobalAsyncStateManager.kt
@@ -108,6 +108,7 @@ class GlobalAsyncStateManager(private val memoryManager: GlobalMemoryManager) {
             convertToGlobalIfNeeded(message)
             preState = false
         }
+        logger.info {"SGX message=$message"}
         // stateType should not change after a conversion.
         Preconditions.checkArgument(stateType == extractStateType(message))