From 07686d9e32d480d8f9b167296ac0d6662f66764f Mon Sep 17 00:00:00 2001 From: Quigley Malcolm Date: Thu, 12 Dec 2024 13:36:15 -0600 Subject: [PATCH] Fix typing issues with `check_forcing_batch_concurrency` --- core/dbt/parser/manifest.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/core/dbt/parser/manifest.py b/core/dbt/parser/manifest.py index 49d0c5162b8..75d9e398ae6 100644 --- a/core/dbt/parser/manifest.py +++ b/core/dbt/parser/manifest.py @@ -1487,14 +1487,17 @@ def check_valid_microbatch_config(self): if not has_input_with_event_time_config: fire_event(MicrobatchModelNoEventTimeInputs(model_name=node.name)) - def check_forcing_batch_concurrency(self): + def check_forcing_batch_concurrency(self) -> None: if self.manifest.use_microbatch_batches(project_name=self.root_project.project_name): adapter = get_adapter(self.root_project) if not adapter.supports(Capability.MicrobatchConcurrency): models_forcing_concurrent_batches = 0 for node in self.manifest.nodes.values(): - if node.config.concurrent_batches is True: + if ( + hasattr(node.config, "concurrent_batches") + and node.config.concurrent_batches is True + ): models_forcing_concurrent_batches += 1 if models_forcing_concurrent_batches > 0: