tests: fix

Author: keenborder786

langgraph/checkpoint/redis/jsonplus_redis.py

@@ -43,12 +43,13 @@ def dumps(self, obj: Any) -> bytes:
         try:
             # Check if this is an Interrupt object that needs special handling
             from langgraph.types import Interrupt
+
             if isinstance(obj, Interrupt):
                 # Serialize Interrupt as a constructor format for proper deserialization
                 return super().dumps(obj)
         except ImportError:
             pass
-        
+
         try:
             # Fast path: Use orjson for JSON-serializable objects
             return orjson.dumps(obj)
@@ -75,7 +76,7 @@ def _revive_if_needed(self, obj: Any) -> Any:
         reconstructed. Without this, messages would remain as dictionaries with
         'lc', 'type', and 'constructor' fields, causing errors when the application
         expects actual message objects with 'role' and 'content' attributes.
-        
+
         This also handles Interrupt objects that may be stored as plain dictionaries
         with 'value' and 'id' keys, reconstructing them as proper Interrupt instances
         to prevent AttributeError when accessing the 'id' attribute.
@@ -93,7 +94,7 @@ def _revive_if_needed(self, obj: Any) -> Any:
                 # This converts {'lc': 1, 'type': 'constructor', ...} back to
                 # the actual LangChain object (e.g., HumanMessage, AIMessage)
                 return self._reviver(obj)
-            
+
             # Check if this looks like an Interrupt object stored as a plain dict
             # Interrupt objects have 'value' and 'id' keys, and possibly nothing else
             # We need to be careful not to accidentally convert other dicts
@@ -106,11 +107,12 @@ def _revive_if_needed(self, obj: Any) -> Any:
                 # Try to reconstruct as an Interrupt object
                 try:
                     from langgraph.types import Interrupt
-                    return Interrupt(value=obj["value"], id=obj["id"])
+
+                    return Interrupt(value=obj["value"], id=obj["id"])  # type: ignore[call-arg]
                 except (ImportError, TypeError, ValueError):
                     # If we can't import or construct Interrupt, fall through
                     pass
-            
+
             # Recursively process nested dicts
             return {k: self._revive_if_needed(v) for k, v in obj.items()}
         elif isinstance(obj, list):

tests/test_async_store.py

@@ -6,13 +6,7 @@
 from uuid import uuid4
 
 import pytest
-from langgraph.store.base import (
-    GetOp,
-    Item,
-    ListNamespacesOp,
-    PutOp,
-    SearchOp,
-)
+from langgraph.store.base import GetOp, Item, ListNamespacesOp, PutOp, SearchOp
 
 from langgraph.store.redis import AsyncRedisStore
 from tests.embed_test_utils import CharacterEmbeddings

tests/test_crossslot_integration.py

@@ -1,9 +1,6 @@
 """Integration tests for CrossSlot error fix in checkpoint operations."""
 
-from langgraph.checkpoint.base import (
-    create_checkpoint,
-    empty_checkpoint,
-)
+from langgraph.checkpoint.base import create_checkpoint, empty_checkpoint
 
 from langgraph.checkpoint.redis import RedisSaver