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