WEBDIENSTE/langgraph
1
0
Fork 0
mirror of https://github.com/langchain-ai/langgraph.git synced 2026-09-10 11:47:51 +02:00
Code Issues Packages Projects Releases Wiki Activity

refactor(channels): inline _clone_empty into copy and from_checkpoint

Browse Source 
The helper was three lines called from exactly two places — inlining
it removes indirection without adding duplication.

Co-Authored-By: Claude Sonnet 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
Sydney Runkle
2026-04-29 09:34:48 -04:00
co-authored by Claude Sonnet 4.6
parent a98ffc95fd
commit 16c09c1bad
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libs/langgraph/langgraph/channels/delta.py
+4 -6
View File
@@ -83,14 +83,10 @@ class DeltaChannel(Generic[Value], BaseChannel[Any, Any, Any]):
and step % self.snapshot_frequency == 0
)
def _clone_empty(self) -> Self:
def copy(self) -> Self:
new = self.__class__(self.operator, snapshot_frequency=self.snapshot_frequency)
new.typ = self.typ # typ may differ from list when set via Annotated injection
new.key = self.key # key is injected externally by the graph builder
return new
def copy(self) -> Self:
new = self._clone_empty()
new.value = self.value if self.value is MISSING else _copy.copy(self.value)
return new
@@ -113,7 +109,9 @@ class DeltaChannel(Generic[Value], BaseChannel[Any, Any, Any]):
* `_DeltaSnapshot(value)`: restore value directly from snapshot.
* plain value (migration from old BinOp blobs): use directly.
"""
new = self._clone_empty()
new = self.__class__(self.operator, snapshot_frequency=self.snapshot_frequency)
new.typ = self.typ # typ may differ from list when set via Annotated injection
new.key = self.key # key is injected externally by the graph builder
if checkpoint is MISSING or checkpoint is DELTA_SENTINEL:
new.value = _empty(new.typ)
elif isinstance(checkpoint, _DeltaSnapshot):