WEBDIENSTE/langgraph
1
0
Fork 0
mirror of https://github.com/langchain-ai/langgraph.git synced 2026-09-28 12:35:08 +02:00
Code Issues Packages Projects Releases Wiki Activity

Support any nr of parts in full_topic_name

Browse Source
This commit is contained in:
Nuno Campos
2023-09-15 11:59:11 +01:00
parent 60b1fe619c
commit 0e80272764
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
permchain/connection.py
+2 -2
View File
@@ -12,9 +12,9 @@ class LogMessage(TypedDict):
class PubSubConnection(ABC):
def full_topic_name(self, prefix: str, topic_name: str) -> str:
def full_topic_name(self, prefix: str, *parts: str) -> str:
"""Return the full topic name for a given prefix and topic name."""
return f"{prefix}:{topic_name}"
return ":".join(map(str, [prefix, *parts]))
@abstractmethod
def iterate(self, prefix: str, topic_name: str, wait: bool) -> Iterator[Any]: