Bump duroxide to 0.1.26, duroxide-pg to 0.1.27, add KV RMW counter test

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

Author: affandar

Cargo.toml

@@ -8,8 +8,8 @@ name = "duroxide_python"
 crate-type = ["cdylib"]
 
 [dependencies]
-duroxide = { version = "0.1.25", features = ["sqlite"] }
-duroxide-pg = { version = "0.1.26" }
+duroxide = { version = "0.1.26", features = ["sqlite"] }
+duroxide-pg = { version = "0.1.27" }
 pyo3 = { version = "0.23", features = ["extension-module"] }
 async-trait = "0.1"
 tokio = { version = "1", features = ["full"] }

tests/test_kv_store.py

@@ -179,3 +179,37 @@ def consumer(ctx, producer_id):
         assert client.get_kv_value(producer_id, "status") == "done"
     finally:
         runtime.shutdown(100)
+
+
+def test_kv_read_modify_write_counter(provider):
+    client = Client(provider)
+    runtime = Runtime(provider, PyRuntimeOptions(dispatcher_poll_interval_ms=50))
+
+    @runtime.register_activity("ProcessBatch")
+    def process_batch(_ctx, input):
+        return f"processed:{input}"
+
+    @runtime.register_orchestration("BatchProcessor")
+    def batch_processor(ctx, _input):
+        for batch_name in ["alpha", "beta", "gamma"]:
+            processed = int(ctx.get_kv_value("batches_processed") or "0")
+            result = yield ctx.schedule_activity("ProcessBatch", batch_name)
+            ctx.set_kv_value("batches_processed", str(processed + 1))
+            ctx.set_kv_value("last_result", result)
+
+        return ctx.get_kv_value("batches_processed") or "0"
+
+    runtime.start()
+
+    try:
+        instance_id = uid("batch-processor")
+        client.start_orchestration(instance_id, "BatchProcessor", "")
+
+        result = client.wait_for_orchestration(instance_id, 5_000)
+        assert result.status == "Completed"
+        assert result.output == "3"
+
+        assert client.get_kv_value(instance_id, "batches_processed") == "3"
+        assert client.get_kv_value(instance_id, "last_result") == "processed:gamma"
+    finally:
+        runtime.shutdown(100)