fix(decorators): async miss-store records carry serializer/hit like sync (LAB-3755)

src/cachekit/decorators/wrapper.py

@@ -1863,6 +1863,8 @@ async def async_wrapper(*args: Any, **kwargs: Any) -> Any:
                                     namespace=namespace or "default",
                                     success=True,
                                     duration_ms=set_duration_ms,
+                                    serializer="rust",
+                                    hit=False,  # Was a miss
                                 )
 
                         except InteropError:
@@ -1945,6 +1947,8 @@ async def async_wrapper(*args: Any, **kwargs: Any) -> Any:
                             namespace=namespace or "default",
                             success=True,
                             duration_ms=set_duration_ms,
+                            serializer="rust",
+                            hit=False,  # Was a miss
                         )
 
                 except InteropError:

tests/unit/test_async_set_record_labels.py

@@ -0,0 +1,91 @@
+"""Async miss-store stats parity (LAB-3755).
+
+The sync wrapper records its miss-store as ``operation="set", serializer="rust",
+hit=False``. The async wrapper's two miss-store sites — under the distributed
+lock and on the no-lock fallback — recorded ``set`` with neither label, so the
+Prometheus sink filed async sets under ``serializer="unknown"`` with no hit
+marker. Both async paths are pinned here through the real decorator stack; the
+backend decides which path runs (``acquire_lock`` present → locked).
+"""
+
+from __future__ import annotations
+
+from collections.abc import AsyncIterator, Iterator
+from contextlib import asynccontextmanager
+from typing import Any
+
+import pytest
+
+from cachekit import cache
+from cachekit.decorators.orchestrator import FeatureOrchestrator
+from cachekit.l1_cache import get_l1_cache_manager
+
+
+class _ByteStore:
+    """Plain byte store without ``acquire_lock``: drives the no-lock miss path."""
+
+    def __init__(self) -> None:
+        self.store: dict[str, bytes] = {}
+
+    def get(self, key: str) -> bytes | None:
+        return self.store.get(key)
+
+    def set(self, key: str, value: bytes, ttl: int | None = None) -> None:
+        self.store[key] = value
+
+    def delete(self, key: str) -> bool:
+        return self.store.pop(key, None) is not None
+
+    def exists(self, key: str) -> bool:
+        return key in self.store
+
+    def health_check(self) -> tuple[bool, dict[str, Any]]:
+        return True, {}
+
+
+class _LockableByteStore(_ByteStore):
+    """Byte store whose lock always acquires: drives the locked miss path."""
+
+    @asynccontextmanager
+    async def acquire_lock(self, key: str, timeout: float, blocking_timeout: float | None = None) -> AsyncIterator[bool]:
+        yield True
+
+
+@pytest.fixture(autouse=True)
+def setup_di_for_redis_isolation() -> Iterator[None]:
+    """Override the root conftest's Redis isolation: the backend is injected, no Redis needed.
+
+    Keep its L1 clear — both parametrized cases share a cache key, and a leaked L1 entry
+    turns the second case into an L1 hit that never reaches the miss-store site.
+    """
+    yield
+    get_l1_cache_manager().clear_all()
+
+
+@pytest.fixture
+def recorded(monkeypatch: pytest.MonkeyPatch) -> list[dict[str, Any]]:
+    """Capture the wrapper's explicit features.record_cache_operation(...) calls, keyword args as passed.
+
+    Patched at the orchestrator, not the collector: record_success() also forwards an
+    operation-context record to the collector, which would shadow the labels under test.
+    """
+    calls: list[dict[str, Any]] = []
+    monkeypatch.setattr(FeatureOrchestrator, "record_cache_operation", lambda self, **kw: calls.append(kw))
+    return calls
+
+
+@pytest.mark.unit
+@pytest.mark.parametrize("backend_cls", [_ByteStore, _LockableByteStore], ids=["no-lock", "locked"])
+async def test_async_miss_store_records_sync_set_labels(recorded: list[dict[str, Any]], backend_cls: type[_ByteStore]) -> None:
+    backend = backend_cls()
+
+    @cache(backend=backend, ttl=60, namespace="async-set-labels")
+    async def compute() -> dict[str, int]:
+        return {"answer": 42}
+
+    assert await compute() == {"answer": 42}
+    assert backend.store  # the miss reached L2, so a set record must exist
+
+    sets = [c for c in recorded if c["operation"] == "set"]
+    assert len(sets) == 1
+    assert (sets[0].get("serializer"), sets[0].get("hit")) == ("rust", False)  # what the sync miss-store passes