From 64bb82210823df26c78f456da6a30da7be0fafcc Mon Sep 17 00:00:00 2001 From: raimundovidaljunior Date: Tue, 15 Apr 2025 12:19:36 +0200 Subject: [PATCH] Removing unnecessary inputs/outputs from command --- .../dag_creator/airflow/operator_creators/dbt_creator.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/dagger/dag_creator/airflow/operator_creators/dbt_creator.py b/dagger/dag_creator/airflow/operator_creators/dbt_creator.py index 9be9ee8..b461306 100644 --- a/dagger/dag_creator/airflow/operator_creators/dbt_creator.py +++ b/dagger/dag_creator/airflow/operator_creators/dbt_creator.py @@ -34,7 +34,8 @@ def _generate_command(self): if self._create_external_athena_table: command.append(f"--create_external_athena_table={self._create_external_athena_table}") for param_name, param_value in self._template_parameters.items(): - command.append( - f"--{param_name}={param_value}" - ) + if param_name == 'output_s3_path': + command.append( + f"--{param_name}={param_value}" + ) return command