From 74f34db9e453df4097280262e54c9eb992f2a1e0 Mon Sep 17 00:00:00 2001 From: Nuno Campos Date: Sun, 22 Sep 2024 12:04:43 -0700 Subject: [PATCH] Fix sync kafka --- libs/scheduler-kafka/langgraph/scheduler/kafka/orchestrator.py | 1 + 1 file changed, 1 insertion(+) diff --git a/libs/scheduler-kafka/langgraph/scheduler/kafka/orchestrator.py b/libs/scheduler-kafka/langgraph/scheduler/kafka/orchestrator.py index a94a3bd0a..39e7b755b 100644 --- a/libs/scheduler-kafka/langgraph/scheduler/kafka/orchestrator.py +++ b/libs/scheduler-kafka/langgraph/scheduler/kafka/orchestrator.py @@ -348,6 +348,7 @@ class KafkaOrchestrator(AbstractContextManager): 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,