style(checkpoint): apply black formatting

Auto-format code with black and isort for checkpoint 3.0 changes.

Author: bsbodden

langgraph/checkpoint/redis/__init__.py

@@ -583,7 +583,9 @@ def put_writes(
                 "idx": WRITES_IDX_MAP.get(channel, idx),
                 "channel": channel,
                 "type": type_,
-                "blob": self._encode_blob(blob),  # Encode bytes to base64 string for Redis
+                "blob": self._encode_blob(
+                    blob
+                ),  # Encode bytes to base64 string for Redis
             }
             writes_objects.append(write_obj)
 

langgraph/checkpoint/redis/aio.py

@@ -1122,7 +1122,9 @@ async def aput_writes(
                 "idx": WRITES_IDX_MAP.get(channel, idx),
                 "channel": channel,
                 "type": type_,
-                "blob": self._encode_blob(blob),  # Encode bytes to base64 string for Redis
+                "blob": self._encode_blob(
+                    blob
+                ),  # Encode bytes to base64 string for Redis
             }
             writes_objects.append(write_obj)
 

langgraph/checkpoint/redis/ashallow.py

@@ -534,7 +534,9 @@ async def aput_writes(
                     "idx": WRITES_IDX_MAP.get(channel, idx),
                     "channel": channel,
                     "type": type_,
-                    "blob": self._encode_blob(blob),  # Encode bytes to base64 string for Redis
+                    "blob": self._encode_blob(
+                        blob
+                    ),  # Encode bytes to base64 string for Redis
                 }
                 writes_objects.append(write_obj)
 

langgraph/checkpoint/redis/base.py

@@ -571,7 +571,9 @@ def put_writes(
                 "idx": WRITES_IDX_MAP.get(channel, idx),
                 "channel": channel,
                 "type": type_,
-                "blob": self._encode_blob(blob),  # Encode bytes to base64 string for Redis
+                "blob": self._encode_blob(
+                    blob
+                ),  # Encode bytes to base64 string for Redis
             }
             writes_objects.append(write_obj)
 
@@ -750,7 +752,9 @@ def _load_writes(
             (
                 task_id,
                 data["channel"],
-                serde.loads_typed((data["type"], BaseRedisSaver._decode_blob_static(data["blob"]))),
+                serde.loads_typed(
+                    (data["type"], BaseRedisSaver._decode_blob_static(data["blob"]))
+                ),
             )
             for (task_id, _), data in task_id_to_data.items()
         ]

langgraph/checkpoint/redis/jsonplus_redis.py

@@ -51,8 +51,7 @@ def _default_handler(self, obj: Any) -> Any:
             # For other objects, encode with constructor args
             # Pass the class and the instance's __dict__ as kwargs
             return self._encode_constructor_args(
-                type(obj),
-                kwargs=obj.__dict__ if hasattr(obj, "__dict__") else {}
+                type(obj), kwargs=obj.__dict__ if hasattr(obj, "__dict__") else {}
             )
         except Exception:
             # For types we can't handle, raise TypeError

langgraph/checkpoint/redis/shallow.py

@@ -529,7 +529,9 @@ def put_writes(
                 "idx": WRITES_IDX_MAP.get(channel, idx),
                 "channel": channel,
                 "type": type_,
-                "blob": self._encode_blob(blob),  # Encode bytes to base64 string for Redis
+                "blob": self._encode_blob(
+                    blob
+                ),  # Encode bytes to base64 string for Redis
             }
             writes_objects.append(write_obj)
 

tests/test_async.py

@@ -518,6 +518,7 @@ async def test_search_writes_async(redis_url: str) -> None:
 
         # Blobs are now base64-encoded in Redis (checkpoint 3.0)
         import base64
+
         assert base64.b64decode(doc1["blob"]).decode() == '"value1"'
         assert base64.b64decode(doc2["blob"]).decode() == '"value2"'
         assert base64.b64decode(doc3["blob"]).decode() == '"value3"'

tests/test_jsonplus_redis_serializer_v3.py

@@ -6,9 +6,10 @@
 """
 
 from langchain_core.messages import AIMessage, HumanMessage
-from langgraph.checkpoint.redis.jsonplus_redis import JsonPlusRedisSerializer
 from langgraph.types import Interrupt
 
+from langgraph.checkpoint.redis.jsonplus_redis import JsonPlusRedisSerializer
+
 
 def test_dumps_typed_returns_bytes_not_string() -> None:
     """Test that dumps_typed returns tuple[str, bytes], not tuple[str, str]."""

tests/test_sync.py

@@ -269,6 +269,7 @@ def test_search_writes(redis_url: str) -> None:
 
         # Blobs are now base64-encoded in Redis (checkpoint 3.0)
         import base64
+
         assert base64.b64decode(doc1["blob"]).decode() == '"value1"'
         assert base64.b64decode(doc2["blob"]).decode() == '"value2"'
         assert base64.b64decode(doc3["blob"]).decode() == '"value3"'