Merge branch 'master' into DX-721

Author: dlawin

data_diff/__main__.py

@@ -316,6 +316,7 @@ def main(conf, run, **kw):
                 dbt_selection=kw["select"],
                 json_output=kw["json_output"],
                 state=state,
+                where_flag=kw["where"],
             )
         else:
             return _data_diff(

data_diff/dbt.py

@@ -70,6 +70,7 @@ def dbt_diff(
     json_output: bool = False,
     state: Optional[str] = None,
     log_status_handler: Optional[LogStatusHandler] = None,
+    where_flag: Optional[str] = None,
 ) -> None:
     print_version_info()
     diff_threads = []
@@ -109,7 +110,7 @@ def dbt_diff(
             if log_status_handler:
                 log_status_handler.set_prefix(f"Diffing {model.alias} \n")
 
-            diff_vars = _get_diff_vars(dbt_parser, config, model)
+            diff_vars = _get_diff_vars(dbt_parser, config, model, where_flag)
 
             # we won't always have a prod path when using state
             # when the model DNE in prod manifest, skip the model diff
@@ -158,6 +159,7 @@ def _get_diff_vars(
     dbt_parser: "DbtParser",
     config: TDatadiffConfig,
     model,
+    where_flag: Optional[str] = None,
 ) -> TDiffVars:
     dev_database = model.database
     dev_schema = model.schema_
@@ -187,7 +189,8 @@ def _get_diff_vars(
         primary_keys=primary_keys,
         connection=dbt_parser.connection,
         threads=dbt_parser.threads,
-        where_filter=datadiff_model_config.where_filter,
+        # --where takes precedence over any model level config
+        where_filter=where_flag or datadiff_model_config.where_filter,
         include_columns=datadiff_model_config.include_columns,
         exclude_columns=datadiff_model_config.exclude_columns,
     )