Add SQL Check Operators to Snowflake Provider #17694
Assignees
Labels
Comments
|
Feel free! |
denimalpaca
added a commit
to denimalpaca/airflow
that referenced
this issue
Aug 19, 2021
The SnowflakeCheckOperator, SnowflakeValueCheckOperator, and SnowflakeIntervalCheckOperators are added as subclasses of their respective SQL Operators. These additions follow the conventions set in the BigQueryOperators subclassing from the same SQL_CheckOperators. This decision was made despite the existing SnowflakeOperator, as subclassing both SnowflakeOperator and a SQL_CheckOperator caused a couple issues: 1. Both operators have an execute method already, so some precaution would be necessary to choose the correct one. 2. An issue with the `sql` parameter occured, where if it was given as a kwarg (sql=sql), then the BaseOperator init() would through an exception for missing args, as if it weren't being added to **kwargs correctly.
kaxil
pushed a commit
that referenced
this issue
Sep 9, 2021
Add three new Snowflake operators based on SQL Checks The SnowflakeCheckOperator, SnowflakeValueCheckOperator, and SnowflakeIntervalCheckOperators are added as subclasses of their respective SQL Operators. These additions follow the conventions set in the BigQueryOperators subclassing from the same SQL_CheckOperators. closes: #17694
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add SnowflakeCheckOperator, SnowflakeValueCheckOperator, and SnowflakeIntervalCheckOperator to Snowflake provider.
Use case / motivation
The SQL operator, as well as other provider DB operators, already support this functionality. It can prove useful for data quality use cases with Snowflake. It should be relatively easy to implement in the same fashion as BigQuery's versions.
Are you willing to submit a PR?
Yep!
Related Issues
Not that I could find.
The text was updated successfully, but these errors were encountered: