Skip to content

Commit

Permalink
Undo
Browse files Browse the repository at this point in the history
  • Loading branch information
nfcampos committed Aug 20, 2024
1 parent 7b4f8ea commit 84da8e2
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 14 deletions.
7 changes: 1 addition & 6 deletions libs/checkpoint/langgraph/checkpoint/serde/jsonplus.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
from zoneinfo import ZoneInfo

from langgraph.checkpoint.serde.base import SerializerProtocol
from langgraph.checkpoint.serde.types import InterruptProtocol, SendProtocol
from langgraph.checkpoint.serde.types import SendProtocol

LC_REVIVER = Reviver()

Expand Down Expand Up @@ -106,11 +106,6 @@ def _default(self, obj):
return self._encode_constructor_args(
obj.__class__, kwargs={"node": obj.node, "arg": obj.arg}
)
elif isinstance(obj, InterruptProtocol):
return self._encode_constructor_args(
obj.__class__,
kwargs={"when": obj.when, "node": obj.node, "value": obj.value},
)
elif isinstance(obj, (bytes, bytearray)):
return self._encode_constructor_args(
obj.__class__, method="fromhex", args=[obj.hex()]
Expand Down
8 changes: 0 additions & 8 deletions libs/checkpoint/langgraph/checkpoint/serde/types.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@
Any,
AsyncGenerator,
Generator,
Literal,
Optional,
Protocol,
Sequence,
Expand Down Expand Up @@ -65,10 +64,3 @@ def __repr__(self) -> str:

def __eq__(self, value: object) -> bool:
...


@runtime_checkable
class InterruptProtocol(Protocol):
when: Literal["before", "during", "after"]
node: str
value: Any

0 comments on commit 84da8e2

Please sign in to comment.