Fix sync kafka

2026-09-06 17:57:49 +02:00 · 2024-09-22 12:04:43 -07:00
parent 644f14991e
commit 74f34db9e4
1 changed files with 1 additions and 0 deletions
@@ -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,