fix: Make planner VirtualConnectorClient also use v1/ prefix. (#3468)

Signed-off-by: Graham King <[email protected]>

Author: grahamking

lib/bindings/python/rust/planner.rs

@@ -102,7 +102,7 @@ impl VirtualConnectorCoordinator {
         let prefix = root_key(&self.0.namespace);
         let inner = self.0.clone();
         pyo3_async_runtimes::tokio::future_into_py(py, async move {
-            let kv_cache = KvCache::new(inner.etcd_client.clone(), "v1", prefix, HashMap::new())
+            let kv_cache = KvCache::new(inner.etcd_client.clone(), prefix, HashMap::new())
                 .await
                 .map_err(to_pyerr)?;
             *inner.kv_cache.lock() = Some(Arc::new(kv_cache));
@@ -497,5 +497,5 @@ fn load(a: &AtomicUsize) -> usize {
 }
 
 fn root_key(namespace: &str) -> String {
-    format!("{namespace}/planner/")
+    format!("v1/{namespace}/planner/")
 }

lib/runtime/src/transports/etcd.rs

@@ -515,14 +515,11 @@ impl KvCache {
     /// Create a new KV cache for the given prefix
     pub async fn new(
         client: Client,
-        version: &str,
         prefix: String,
         initial_values: HashMap<String, Vec<u8>>,
     ) -> Result<Self> {
         let mut cache = HashMap::new();
 
-        let prefix = format!("{version}/{prefix}");
-
         // First get all existing keys with this prefix
         let existing_kvs = client.kv_get_prefix(&prefix).await?;
         for kv in existing_kvs {
@@ -712,15 +709,15 @@ mod tests {
 
         // Create a unique test prefix to avoid conflicts with other tests
         let test_id = uuid::Uuid::new_v4().to_string();
-        let prefix = format!("test_kv_cache_{}/", test_id);
+        let prefix = format!("v1/test_kv_cache_{}/", test_id);
 
         // Initial values
         let mut initial_values = HashMap::new();
         initial_values.insert("key1".to_string(), b"value1".to_vec());
         initial_values.insert("key2".to_string(), b"value2".to_vec());
 
         // Create the KV cache
-        let kv_cache = KvCache::new(client.clone(), "v1", prefix.clone(), initial_values).await?;
+        let kv_cache = KvCache::new(client.clone(), prefix.clone(), initial_values).await?;
 
         // Test get
         let value1 = kv_cache.get("key1").await;