WEBDIENSTE/langgraph
1
0
Fork 0
mirror of https://github.com/langchain-ai/langgraph.git synced 2026-08-26 17:42:24 +02:00
Code Issues Packages Projects Releases Wiki Activity

Add comment

Browse Source
This commit is contained in:
Nuno Campos
2023-09-15 11:59:24 +01:00
parent 0e80272764
commit 02b5c77943
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
permchain/pubsub.py
+1
View File
@@ -51,6 +51,7 @@ class PubSub(Runnable[Any, Any], ABC):
run_manager: CallbackManagerForChainRun,
config: RunnableConfig,
) -> Iterator[Any]:
# Split processes into subscribers and reducers, and group by topic
subscribers: defaultdict[str, list[RunnableSubscriber[Any]]] = defaultdict(list)
reducers: defaultdict[str, list[RunnableReducer[Any]]] = defaultdict(list)
for process in self.processes: