diff --git a/libs/scheduler-kafka/langgraph/scheduler/kafka/orchestrator.py b/libs/scheduler-kafka/langgraph/scheduler/kafka/orchestrator.py
index 9f6d4110f..adb4ce04d 100644
--- a/libs/scheduler-kafka/langgraph/scheduler/kafka/orchestrator.py
+++ b/libs/scheduler-kafka/langgraph/scheduler/kafka/orchestrator.py
@@ -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,