diff --git a/airflow_dbt/hooks/dbt_hook.py b/airflow_dbt/hooks/dbt_hook.py index fb409f5..0b4caf0 100644 --- a/airflow_dbt/hooks/dbt_hook.py +++ b/airflow_dbt/hooks/dbt_hook.py @@ -110,12 +110,12 @@ def run_cli(self, *command): if self.full_refresh: dbt_cmd.extend(['--full-refresh']) - if self.verbose: - self.log.info(" ".join(dbt_cmd)) - if self.warn_error: dbt_cmd.insert(1, '--warn-error') + if self.verbose: + self.log.info(" ".join(dbt_cmd)) + sp = subprocess.Popen( dbt_cmd, stdout=subprocess.PIPE,