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