Return input from RunnablePublisherEach

This commit is contained in:
Nuno Campos
2023-09-15 11:58:39 +01:00
parent f12f501c79
commit 60b1fe619c
+1
View File
@@ -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]):