Snowflake SQL API Operator Async

The Snowflake SQL API allows submitting multiple SQL statements in a single request. In combination with aiohttp, make post request to submit SQL statements for execution, poll to check the status of the execution of a statement. Fetch query results concurrently SnowflakeSqlApiOperatorAsync.

snowflake_op_sql_multiple_stmt = SnowflakeSqlApiOperatorAsync(
    task_id="snowflake_op_sql_multiple_stmt",
    sql="create or replace table user_test (i int); insert into user_test (i) "
    "values (200); insert into user_test (i) values (300); select i from user_test order by i;",
    statement_count=4,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/snowflake/example_dags/example_snowflake_sql_api.py