From 07c9199d18d443407466264ab5641062c1960068 Mon Sep 17 00:00:00 2001 From: Nuno Campos Date: Mon, 16 Oct 2023 10:47:20 +0100 Subject: [PATCH] join(question, draft) -> join([question, draft]) --- examples/runnable-pregel.py | 2 +- permchain/pregel.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/runnable-pregel.py b/examples/runnable-pregel.py index a0c60f4c4..5ba811ed7 100644 --- a/examples/runnable-pregel.py +++ b/examples/runnable-pregel.py @@ -98,7 +98,7 @@ editor = ( reviser = ( # subscribe to new values of "notes" channel, # and join them with the current values of "question" and "draft" - Pregel.subscribe_to(["notes"]).join("question", "draft") + Pregel.subscribe_to(["notes"]).join(["question", "draft"]) | reviser_chain | Pregel.send_to("draft") ) diff --git a/permchain/pregel.py b/permchain/pregel.py index 10f42532f..fde0346e1 100644 --- a/permchain/pregel.py +++ b/permchain/pregel.py @@ -101,7 +101,7 @@ class PregelInvoke(RunnableBinding): kwargs: Mapping[str, Any] = Field(default_factory=dict) - def join(self, *channels: str) -> PregelInvoke: + def join(self, channels: Sequence[str]) -> PregelInvoke: joiner = RunnablePassthrough.assign( **{chan: PregelRead(chan) for chan in channels} )