Fix extension order of dbt_cmd

tactivos · Aug 21, 2020 · 842da10 · 842da10
1 parent bc4bd9d
commit 842da10
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/airflow_dbt/hooks/dbt_hook.py b/airflow_dbt/hooks/dbt_hook.py
@@ -83,6 +83,12 @@ def run_cli(self, *command):
 
         if self.vars is not None:
             dbt_cmd.extend(['--vars', self._dump_vars()])
+
+        if self.data_test:
+            dbt_cmd.extend(['--data'])
+
+        if self.schema_test:
+            dbt_cmd.extend(['--schema'])
 
         if self.models is not None:
             dbt_cmd.extend(['--models', self.models])
@@ -96,12 +102,6 @@ def run_cli(self, *command):
         if self.full_refresh:
             dbt_cmd.extend(['--full-refresh'])
 
-        if self.data_test:
-            dbt_cmd.extend(['--data'])
-
-        if self.schema_test:
-            dbt_cmd.extend(['--schema'])
-
         sp = subprocess.Popen(
             dbt_cmd,
             stdout=subprocess.PIPE,