From 02b5c77943d598cec5bda85bd51639fd918bef3e Mon Sep 17 00:00:00 2001
From: Nuno Campos <nuno@boringbits.io>
Date: Fri, 15 Sep 2023 11:59:24 +0100
Subject: [PATCH] Add comment

---
 permchain/pubsub.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/permchain/pubsub.py b/permchain/pubsub.py
index f01886776..63b4f306b 100644
--- a/permchain/pubsub.py
+++ b/permchain/pubsub.py
@@ -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: