feldera · abhizer · Jun 27, 2026 · Jun 27, 2026 · Jun 27, 2026
diff --git a/python/pyproject.toml b/python/pyproject.toml
@@ -8,7 +8,7 @@ readme = "README.md"
 description = "The feldera python client"
 version = "0.315.0"
 license = "MIT"
-requires-python = ">=3.10"
+requires-python = ">=3.10,<3.14"
 authors = [
     { "name" = "Feldera Team", "email" = "dev@feldera.com" },
 ]

diff --git a/python/tests/platform/test_checkpoint_sync.py b/python/tests/platform/test_checkpoint_sync.py
@@ -187,6 +187,40 @@ def checkpoint_created() -> bool:
         )
         return chk_uuid, chk_steps
 
+    def _latest_checkpoint(self, processed=None, timeout_s=10.0):
+        """Return (chk_uuid, chk_steps) for the most recently created checkpoint.
+
+        If *processed* is given, polls until the latest checkpoint covers at
+        least that many records (summed across pods for multihost pipelines),
+        up to *timeout_s* seconds.  Use after checkpoint(wait=True).
+        """
+        chk_uuid = None
+        chk_steps = None
+
+        def checkpoint_visible() -> bool:
+            nonlocal chk_uuid, chk_steps
+            chks = self.pipeline.checkpoints()
+            if not chks:
+                return False
+            latest = max(chks, key=lambda c: c.steps)
+            if processed is not None:
+                step_total = sum(
+                    c.processed_records for c in chks if c.steps == latest.steps
+                )
+                if step_total < processed:
+                    return False
+            chk_uuid = latest.uuid
+            chk_steps = latest.steps
+            return True
+
+        wait_for_condition(
+            "latest checkpoint visible with sufficient processed records",
+            checkpoint_visible,
+            timeout_s=timeout_s,
+            poll_interval_s=0.5,
+        )
+        return chk_uuid, chk_steps
+
     def _checkpoint_steps(self, synced_uuid) -> Optional[int]:
         """Return the step count for *synced_uuid*, or None if not found."""
         return next(
@@ -381,11 +415,15 @@ def test_automated_checkpoint_sync(self):
     @enterprise_only
     def test_automated_checkpoint_sync1(self):
         # Manual checkpoint, automated sync.
-        self._configure_and_start(ft_interval=5, push_interval=10)
-        _, got_before = self._insert_data_and_wait()
+        ft_interval = 5
+        self._configure_and_start(ft_interval=ft_interval, push_interval=10)
+        processed, got_before = self._insert_data_and_wait()
         self.pipeline.checkpoint(wait=True)
         time.sleep(1)
-        self._wait_for_automated_sync()
+        chk_uuid, chk_steps = self._latest_checkpoint(
+            processed, timeout_s=2 * ft_interval
+        )
+        self._wait_for_automated_sync(chk_uuid, chk_steps)
 
         self._restart_from_checkpoint("latest")
 

diff --git a/python/tests/platform/test_output_buffer_size_limit.py b/python/tests/platform/test_output_buffer_size_limit.py
@@ -104,8 +104,10 @@ def test_output_buffer_flushes_at_default_size_limit(pipeline_name):
         # count past the cap.
         wait_for_condition(
             "completed-record count advances past the default buffer size cap",
-            lambda: (pipeline.stats().global_metrics.total_completed_records or 0)
-            >= _DEFAULT_MAX_OUTPUT_BUFFER_SIZE_RECORDS,
+            lambda: (
+                (pipeline.stats().global_metrics.total_completed_records or 0)
+                >= _DEFAULT_MAX_OUTPUT_BUFFER_SIZE_RECORDS
+            ),
             timeout_s=600.0,
             poll_interval_s=2.0,
         )