denimalpaca commented on code in PR #26761:
URL: https://github.com/apache/airflow/pull/26761#discussion_r994639740
##########
airflow/providers/common/sql/operators/sql.py:
##########
@@ -241,12 +241,13 @@ def __init__(
self.column_mapping = column_mapping
self.partition_clause = partition_clause
- checks_sql_list = []
- for column, checks in self.column_mapping.items():
- for check, check_values in checks.items():
- self._column_mapping_validation(check, check_values)
- checks_sql_list.append(self._generate_sql_query(column, checks))
- checks_sql = "UNION ALL".join(checks_sql_list)
+ def _build_checks_sql():
Review Comment:
This change may also need to be made in the BigQuery version of the operator!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
