bump CDK version for destination-snowflake, Remove nullability of IntegrationRunner.getThreadCreationInfo (#38586)

stephane-airbyte · web-flow · commit 94663440a2e7 · 2024-05-23T16:53:10.000-07:00
diff --git a/airbyte-cdk/java/airbyte-cdk/README.md b/airbyte-cdk/java/airbyte-cdk/README.md
@@ -176,6 +176,14 @@ corresponds to that version.
 |:--------|:-----------|:-----------------------------------------------------------|:---------------------------------------------------------------------------------------------------------------------------------------------------------------|
 | 0.35.11 | 2024-05-23 | [\#38357](https://github.com/airbytehq/airbyte/pull/38357) | This release fixes an error on the previous release.                                                                                                           |
 | 0.35.10 | 2024-05-23 | [\#38357](https://github.com/airbytehq/airbyte/pull/38357) | Add shared code for db sources stream status trace messages and testing.                                                                                       |
+| 0.35.9  | 2024-05-23 | [\#38586](https://github.com/airbytehq/airbyte/pull/38586) | code cleanup                                                                    |
+| 0.35.9  | 2024-05-23 | [\#37583](https://github.com/airbytehq/airbyte/pull/37583) | code cleanup                                                                    |
+| 0.35.9  | 2024-05-23 | [\#37555](https://github.com/airbytehq/airbyte/pull/37555) | code cleanup                                                                    |
+| 0.35.9  | 2024-05-23 | [\#37540](https://github.com/airbytehq/airbyte/pull/37540) | code cleanup                                                                    |
+| 0.35.9  | 2024-05-23 | [\#37539](https://github.com/airbytehq/airbyte/pull/37539) | code cleanup                                                                    |
+| 0.35.9  | 2024-05-23 | [\#37538](https://github.com/airbytehq/airbyte/pull/37538) | code cleanup                                                                    |
+| 0.35.9  | 2024-05-23 | [\#37537](https://github.com/airbytehq/airbyte/pull/37537) | code cleanup                                                                    |
+| 0.35.9  | 2024-05-23 | [\#37518](https://github.com/airbytehq/airbyte/pull/37518) | code cleanup                                                                    |
 | 0.35.8  | 2024-05-22 | [\#38572](https://github.com/airbytehq/airbyte/pull/38572) | Add a temporary static method to decouple SnowflakeDestination from AbstractJdbcDestination                                                                    |
 | 0.35.7  | 2024-05-20 | [\#38357](https://github.com/airbytehq/airbyte/pull/38357) | Decouple create namespace from per stream operation interface.                                                                                                 |
 | 0.35.6  | 2024-05-17 | [\#38107](https://github.com/airbytehq/airbyte/pull/38107) | New interfaces for Destination connectors to plug into AsyncStreamConsumer                                                                                     |
diff --git a/airbyte-cdk/java/airbyte-cdk/core/src/main/kotlin/io/airbyte/cdk/integrations/base/IntegrationRunner.kt b/airbyte-cdk/java/airbyte-cdk/core/src/main/kotlin/io/airbyte/cdk/integrations/base/IntegrationRunner.kt
@@ -385,8 +385,8 @@ internal constructor(
             }
 
         @JvmStatic
-        fun getThreadCreationInfo(thread: Thread): ThreadCreationInfo? {
-            return getMethod.invoke(threadCreationInfo, thread) as ThreadCreationInfo?
+        fun getThreadCreationInfo(thread: Thread): ThreadCreationInfo {
+            return getMethod.invoke(threadCreationInfo, thread) as ThreadCreationInfo
         }
 
         /**
diff --git a/airbyte-integrations/connectors/destination-snowflake/build.gradle b/airbyte-integrations/connectors/destination-snowflake/build.gradle
@@ -3,7 +3,7 @@ plugins {
 }
 
 airbyteJavaConnector {
-    cdkVersionRequired = '0.35.8'
+    cdkVersionRequired = '0.35.9'
     features = ['db-destinations', 's3-destinations', 'typing-deduping']
     useLocalCdk = false
 }
diff --git a/airbyte-integrations/connectors/destination-snowflake/metadata.yaml b/airbyte-integrations/connectors/destination-snowflake/metadata.yaml
@@ -5,7 +5,7 @@ data:
   connectorSubtype: database
   connectorType: destination
   definitionId: 424892c4-daac-4491-b35d-c6688ba547ba
-  dockerImageTag: 3.8.2
+  dockerImageTag: 3.8.3
   dockerRepository: airbyte/destination-snowflake
   documentationUrl: https://docs.airbyte.com/integrations/destinations/snowflake
   githubIssueLabel: destination-snowflake
diff --git a/airbyte-integrations/connectors/destination-snowflake/src/main/kotlin/io/airbyte/integrations/destination/snowflake/SnowflakeDestination.kt b/airbyte-integrations/connectors/destination-snowflake/src/main/kotlin/io/airbyte/integrations/destination/snowflake/SnowflakeDestination.kt
@@ -248,7 +248,7 @@ constructor(
 
 fun main(args: Array<String>) {
     IntegrationRunner.addOrphanedThreadFilter { t: Thread ->
-        for (stackTraceElement in IntegrationRunner.getThreadCreationInfo(t)?.stack!!) {
+        for (stackTraceElement in IntegrationRunner.getThreadCreationInfo(t).stack) {
             val stackClassName = stackTraceElement.className
             val stackMethodName = stackTraceElement.methodName
             if (
diff --git a/docs/integrations/destinations/snowflake.md b/docs/integrations/destinations/snowflake.md
@@ -276,6 +276,7 @@ desired namespace.
 
 | Version         | Date       | Pull Request                                               | Subject                                                                                                                                                          |
 |:----------------|:-----------|:-----------------------------------------------------------|:-----------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| 3.8.3           | 2024-05-23 | [\#38586](https://github.com/airbytehq/airbyte/pull/38586) | Bump CDK version                                                                            |
 | 3.8.2           | 2024-05-22 | [\#38553](https://github.com/airbytehq/airbyte/pull/38553) | Remove `SwitchingDestination` and `AbstractJdbcDestination` dependency in destination                                                                            |
 | 3.8.1           | 2024-05-22 | [\#38568](https://github.com/airbytehq/airbyte/pull/38568) | Adopt latest CDK                                                                                                                                                 |
 | 3.8.0           | 2024-05-08 | [\#37715](https://github.com/airbytehq/airbyte/pull/37715) | Remove option for incremental typing and deduping                                                                                                                |

Original file line number	Diff line number	Diff line change
`@@ -385,8 +385,8 @@ internal constructor(`
`385`	`385`	`}`
`386`	`386`
`387`	`387`	`@JvmStatic`
`388`		`- fun getThreadCreationInfo(thread: Thread): ThreadCreationInfo? {`
`389`		`- return getMethod.invoke(threadCreationInfo, thread) as ThreadCreationInfo?`
	`388`	`+ fun getThreadCreationInfo(thread: Thread): ThreadCreationInfo {`
	`389`	`+ return getMethod.invoke(threadCreationInfo, thread) as ThreadCreationInfo`
`390`	`390`	`}`
`391`	`391`
`392`	`392`	`/**`
Original file line number	Diff line number	Diff line change
`@@ -3,7 +3,7 @@ plugins {`
`3`	`3`	`}`
`4`	`4`
`5`	`5`	`airbyteJavaConnector {`
`6`		`- cdkVersionRequired = '0.35.8'`
	`6`	`+ cdkVersionRequired = '0.35.9'`
`7`	`7`	`features = ['db-destinations', 's3-destinations', 'typing-deduping']`
`8`	`8`	`useLocalCdk = false`
`9`	`9`	`}`