sanity

rodireich · rodireich · commit 0ff9ed6a4a30 · 2025-09-18T22:24:26.000-07:00
diff --git a/airbyte-integrations/connectors/source-postgres/src/main/kotlin/io/airbyte/integrations/source/postgres/PostgresSourceJdbcPartitionFactory.kt b/airbyte-integrations/connectors/source-postgres/src/main/kotlin/io/airbyte/integrations/source/postgres/PostgresSourceJdbcPartitionFactory.kt
@@ -114,7 +114,7 @@ class PostgresSourceJdbcPartitionFactory(
             false -> null
         }
         val fileNodeChange: FilenodeChangeType =
-            ensureNoStreamFilenodeChanged(streamState, filenode)
+            detectStreamFilenodeChange(streamState, filenode)
 
         if (opaqueStateValue == null) {
             return coldStart(streamState, filenode)
@@ -258,7 +258,7 @@ class PostgresSourceJdbcPartitionFactory(
         }
     }
 
-    private fun ensureNoStreamFilenodeChanged(
+    private fun detectStreamFilenodeChange(
         streamState: PostgresSourceJdbcStreamState,
         filenode: Filenode?
     ): FilenodeChangeType =

Original file line number	Diff line number	Diff line change
`@@ -114,7 +114,7 @@ class PostgresSourceJdbcPartitionFactory(`
`114`	`114`	`false -> null`
`115`	`115`	`}`
`116`	`116`	`val fileNodeChange: FilenodeChangeType =`
`117`		`- ensureNoStreamFilenodeChanged(streamState, filenode)`
	`117`	`+ detectStreamFilenodeChange(streamState, filenode)`
`118`	`118`
`119`	`119`	`if (opaqueStateValue == null) {`
`120`	`120`	`return coldStart(streamState, filenode)`
`@@ -258,7 +258,7 @@ class PostgresSourceJdbcPartitionFactory(`
`258`	`258`	`}`
`259`	`259`	`}`
`260`	`260`
`261`		`- private fun ensureNoStreamFilenodeChanged(`
	`261`	`+ private fun detectStreamFilenodeChange(`
`262`	`262`	`streamState: PostgresSourceJdbcStreamState,`
`263`	`263`	`filenode: Filenode?`
`264`	`264`	`): FilenodeChangeType =`