py: docs: fix python version in docs

abhizer · abhizer · commit 3de9940f91a2 · 2026-03-12T10:16:57.000Z
Configures python docs to automatically use the python package version.

+ clippy fixes

Signed-off-by: Abhinav Gyawali &lt;22275402+abhizer@users.noreply.github.com&gt;
diff --git a/crates/feldera-types/src/config.rs b/crates/feldera-types/src/config.rs
@@ -592,6 +592,7 @@ pub struct SyncConfig {
     /// The pipeline **never writes** to `read_bucket`.
     ///
     /// Must point to a different location than `bucket`.
+    #[serde(default)]
     pub read_bucket: Option<String>,
 }
 
@@ -615,12 +616,13 @@ Standby mode requires `start_from_checkpoint` to be set.
 Consider setting `start_from_checkpoint` to `"latest"`."#.to_owned());
         }
 
-        if let Some(ref rb) = self.read_bucket {
-            if rb == &self.bucket {
-                return Err(
-                    "invalid sync config: `read_bucket` and `bucket` must point to different locations".to_owned()
-                );
-            }
+        if let Some(ref rb) = self.read_bucket
+            && rb == &self.bucket
+        {
+            return Err(
+                "invalid sync config: `read_bucket` and `bucket` must point to different locations"
+                    .to_owned(),
+            );
         }
 
         Ok(())
diff --git a/python/docs/conf.py b/python/docs/conf.py
@@ -8,13 +8,14 @@
 
 import os
 import sys
+from importlib.metadata import version as _pkg_version
 
 sys.path.insert(0, os.path.abspath(".."))
 
 project = "Feldera Python SDK"
 copyright = "2024, Feldera"
 author = "Feldera"
-release = "0.0.1"
+release = _pkg_version("feldera")
 
 # -- General configuration ---------------------------------------------------
 # https://www.sphinx-doc.org/en/master/usage/configuration.html#general-configuration
diff --git a/python/tests/platform/test_checkpoint_sync.py b/python/tests/platform/test_checkpoint_sync.py
@@ -49,8 +49,8 @@ def storage_cfg(
         "standby": standby,
         "pull_interval": pull_interval,
         "push_interval": push_interval,
-        "retention_min_count": retention_min_age,
-        "retention_min_age": retention_min_count,
+        "retention_min_count": retention_min_count,
+        "retention_min_age": retention_min_age,
     }
     if read_bucket is not None:
         sync["read_bucket"] = read_bucket
@@ -323,7 +323,7 @@ def test_standby_activation_from_uuid(self):
     @single_host_only
     def test_standby_fallback(self, from_uuid: bool = False):
         # Step 1: Start main pipeline
-        storage_config = storage_cfg(self.pipeline.name)
+        storage_config = storage_cfg(self.pipeline.name, retention_min_age=1)
         ft = FaultToleranceModel.AtLeastOnce
         self.pipeline.set_runtime_config(
             RuntimeConfig(
