snowflake.hooks.snowflake

Module Contents

Classes

SnowflakeHookAsync

class snowflake.hooks.snowflake.SnowflakeHookAsync

Bases: airflow.providers.snowflake.hooks.snowflake.SnowflakeHook

run(self, sql, autocommit=False, parameters=None)

Runs a SQL command or a list of SQL commands.

Parameters

• sql (Union[str, List[str]]) – the sql string to be executed with possibly multiple statements, or a list of sql statements to execute

• autocommit (bool) – What to set the connection’s autocommit setting to before executing the query.

• parameters (Optional[dict]) – The parameters to render the SQL query with.

check_query_output(self, query_ids)

Once the query is finished fetch the result and log it in airflow

async get_query_status(self, query_ids)

Get the Query status by query ids.