Skip to content

Commit d5002d4

Browse files
committed
Fix edge emission logic to correctly check source generation
1 parent 6ad8771 commit d5002d4

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

langgraphics/streamer.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,7 @@ async def broadcast(self, message: dict[str, Any]) -> None:
124124

125125
async def _emit_edge(self, target: str) -> None:
126126
for source in self.predecessors.get(target, set()):
127-
if src_gen := self.generation.get(source) is None:
127+
if (src_gen := self.generation.get(source)) is None:
128128
continue
129129
if (key := (source, src_gen, target)) in self.linked:
130130
continue

0 commit comments

Comments
 (0)