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,