Fix sync kafka

langchain-ai · Sep 22, 2024 · 74f34db · 74f34db
1 parent 644f149
commit 74f34db
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/libs/scheduler-kafka/langgraph/scheduler/kafka/orchestrator.py b/libs/scheduler-kafka/langgraph/scheduler/kafka/orchestrator.py
@@ -348,6 +348,7 @@ def attempt(self, msg: MessageToOrchestrator) -> None:
             specs=graph.channels,
             output_keys=graph.output_channels,
             stream_keys=graph.stream_channels,
+            check_subgraphs=False,
         ) as loop:
             if loop.tick(
                 input_keys=graph.input_channels,