Snowflake Operator Async¶
To executes SQL code in a Snowflake database
SnowflakeOperatorAsync
.
snowflake_op_sql_str = SnowflakeOperatorAsync(
task_id="snowflake_op_sql_str",
sql=CREATE_TABLE_SQL_STRING,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/snowflake/example_dags/example_snowflake.py