Change log about dropping oldest finished partition to debug

tolik0 · tolik0 · commit d3b3f52330e8 · 2025-06-10T18:28:46.000+03:00
diff --git a/airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py b/airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py
@@ -335,7 +335,7 @@ def _ensure_partition_limit(self) -> None:
                         oldest_partition = self._cursor_per_partition.pop(
                             partition_key
                         )  # Remove the oldest partition
-                        logger.warning(
+                        logger.debug(
                             f"The maximum number of partitions has been reached. Dropping the oldest finished partition: {oldest_partition}. Over limit: {self._number_of_partitions - self.DEFAULT_MAX_PARTITIONS_NUMBER}."
                         )
                         break

Original file line number	Diff line number	Diff line change
`@@ -335,7 +335,7 @@ def _ensure_partition_limit(self) -> None:`
`335`	`335`	`oldest_partition = self._cursor_per_partition.pop(`
`336`	`336`	`partition_key`
`337`	`337`	`) # Remove the oldest partition`
`338`		`- logger.warning(`
	`338`	`+ logger.debug(`
`339`	`339`	`f"The maximum number of partitions has been reached. Dropping the oldest finished partition: {oldest_partition}. Over limit: {self._number_of_partitions - self.DEFAULT_MAX_PARTITIONS_NUMBER}."`
`340`	`340`	`)`
`341`	`341`	`break`