From 60b1fe619c37d40b786db9560d96f60b9ed9c2b3 Mon Sep 17 00:00:00 2001 From: Nuno Campos Date: Fri, 15 Sep 2023 11:58:39 +0100 Subject: [PATCH] Return input from RunnablePublisherEach --- permchain/topic.py | 1 + 1 file changed, 1 insertion(+) diff --git a/permchain/topic.py b/permchain/topic.py index b1369ff76..9456caf06 100644 --- a/permchain/topic.py +++ b/permchain/topic.py @@ -158,6 +158,7 @@ class RunnablePublisherEach(RunnablePublisher[Sequence[T]]): ) -> Sequence[T]: for item in input: super().invoke(item, config) + return input class RunnableCurrentValue(Serializable, Runnable[Any, T]):