fixup! fixup! fixup! fixup! fixup! tmp

Author: Lee-W

airflow-core/src/airflow/assets/manager.py

@@ -391,7 +391,7 @@ def _queue_partitioned_dags(
             if TYPE_CHECKING:
                 assert isinstance(timetable, PartitionedAssetTimetable)
 
-            if asset_model := session.scalar(select(AssetModel).where(AssetModel.id == asset_id)) is None:
+            if (asset_model := session.scalar(select(AssetModel).where(AssetModel.id == asset_id))) is None:
                 raise ValueError()
 
             target_key = timetable.get_partition_mapper(

airflow-core/src/airflow/timetables/simple.py

@@ -267,14 +267,14 @@ def serialize(self) -> dict[str, Any]:
 
         return {
             "asset_condition": encode_asset_like(self.asset_condition),
-            "partition_mapper": self.default_partition_mapper.serialize(),
+            "default_partition_mapper": self.default_partition_mapper.serialize(),
             "_partition_mappers_by_name": [
                 (name, encode_partition_mapper(partition_mapper))
                 for name, partition_mapper in self._partition_mappers_by_name.items()
             ],
             "_partition_mappers_by_uri": [
                 (uri, encode_partition_mapper(partition_mapper))
-                for uri, partition_mapper in self._partition_mappers_by_ui.items()
+                for uri, partition_mapper in self._partition_mappers_by_uri.items()
             ],
         }
 
@@ -285,7 +285,7 @@ def deserialize(cls, data: dict[str, Any]) -> Timetable:
 
         timetable = cls(
             assets=decode_asset_like(data["asset_condition"]),
-            default_partition_mapper=decode_partition_mapper(data["partition_mapper"]),
+            default_partition_mapper=decode_partition_mapper(data["default_partition_mapper"]),
         )
         timetable._partition_mappers_by_name = {
             name: decode_partition_mapper(ser_partition_mapper)