Lint

2026-09-10 03:37:51 +02:00 · 2025-05-08 16:50:24 -07:00
parent f1c1eaf229
commit 4761eb7696
1 changed files with 2 additions and 0 deletions
@@ -151,6 +151,7 @@ class AsyncKafkaOrchestrator(AbstractAsyncContextManager):
            msg["input"],
            config=ensure_config(msg["config"]),
            stream=None,
+            cache=self.graph.cache,
            store=self.graph.store,
            checkpointer=self.graph.checkpointer,
            nodes=graph.nodes,
@@ -338,6 +339,7 @@ class KafkaOrchestrator(AbstractContextManager):
            msg["input"],
            config=ensure_config(msg["config"]),
            stream=None,
+            cache=self.graph.cache,
            store=self.graph.store,
            checkpointer=self.graph.checkpointer,
            nodes=graph.nodes,