Address review feedback

doc/changes/DM-39582.removal.md

@@ -0,0 +1 @@
+Deprecate reconstituteDimensions argument from `Quantum.from_simple`.

python/lsst/daf/butler/core/datastoreRecordData.py

@@ -71,11 +71,6 @@ def direct(
 
         This method should only be called when the inputs are trusted.
         """
-        key = frozenset(dataset_ids)
-        cache = PersistenceContextVars.serializedDatastoreRecordMapping.get()
-        if cache is not None and (value := cache.get(key)) is not None:
-            return value
-
         data = SerializedDatastoreRecordData.__new__(cls)
         setter = object.__setattr__
         # JSON makes strings out of UUIDs, need to convert them back
@@ -89,8 +84,6 @@ def direct(
                     if (id := record.get("dataset_id")) is not None:
                         record["dataset_id"] = uuid.UUID(id) if isinstance(id, str) else id
         setter(data, "records", records)
-        if cache is not None:
-            cache[key] = data
         return data
 
 

python/lsst/daf/butler/core/persistenceContext.py

@@ -32,7 +32,7 @@
 if TYPE_CHECKING:
     from .datasets.ref import DatasetRef
     from .datasets.type import DatasetType, SerializedDatasetType
-    from .datastoreRecordData import DatastoreRecordData, SerializedDatastoreRecordData
+    from .datastoreRecordData import DatastoreRecordData 
     from .dimensions._coordinate import DataCoordinate, SerializedDataCoordinate
     from .dimensions._records import DimensionRecord, SerializedDimensionRecord
 
@@ -99,12 +99,6 @@ class PersistenceContextVars:
     r"""A cache of `SerializedDimensionRecord`\ s.
     """
 
-    serializedDatastoreRecordMapping: ContextVar[
-        dict[frozenset[str | uuid.UUID], SerializedDatastoreRecordData] | None
-    ] = ContextVar("serializedDatastoreRecordMapping", default=None)
-    r"""A cache of `SerializedDatastoreRecord`\ s.
-    """
-
     loadedTypes: ContextVar[dict[tuple[str, str], DatasetType] | None] = ContextVar(
         "loadedTypes", default=None
     )

python/lsst/daf/butler/core/quantum.py

@@ -29,6 +29,7 @@
 from typing import Any
 
 from lsst.utils import doImportType
+from lsst.utils.introspection import find_outside_stacklevel
 from pydantic import BaseModel
 
 from .datasets import DatasetRef, DatasetType, SerializedDatasetRef, SerializedDatasetType
@@ -416,7 +417,8 @@ def from_simple(
         if reconstitutedDimensions is not None:
             warnings.warn(
                 "The reconstitutedDimensions argument is now ignored and may be removed after v 27",
-                category=DeprecationWarning,
+                category=FutureWarning,
+                stacklevel=find_outside_stacklevel("lsst.daf.butler"),
             )
 
         # Unpersist all the init inputs

python/lsst/daf/butler/transfers/_yaml.py

@@ -25,7 +25,7 @@
 
 import uuid
 import warnings
-from collections import defaultdict
+from collections import UserDict, defaultdict
 from collections.abc import Iterable, Mapping
 from datetime import datetime
 from typing import IO, TYPE_CHECKING, Any
@@ -64,7 +64,21 @@
 this version of the code.
 """
 
-_refIntId2UUID = defaultdict[int, uuid.UUID](uuid.uuid4)
+
+class _RefMapper(UserDict[int, uuid.UUID]):
+    """Create a local dict subclass which creates new deterministic UUID for
+    missing keys.
+    """
+
+    _namespace = uuid.UUID("4d4851f4-2890-4d41-8779-5f38a3f5062b")
+
+    def __missing__(self, key: int) -> uuid.UUID:
+        newUUID = uuid.uuid3(namespace=self._namespace, name=str(key))
+        self[key] = newUUID
+        return newUUID
+
+
+_refIntId2UUID = _RefMapper()
 
 
 def _uuid_representer(dumper: yaml.Dumper, data: uuid.UUID) -> yaml.Node: