airflow.providers.snowflake.triggers.snowflake_trigger

Module Contents

Classes

SnowflakeSqlApiTrigger

Fetch the status for the query ids passed.
class airflow.providers.snowflake.triggers.snowflake_trigger.SnowflakeSqlApiTrigger(poll_interval, query_ids, snowflake_conn_id, token_life_time, token_renewal_delta)[source]

Bases: airflow.triggers.base.BaseTrigger

Fetch the status for the query ids passed.

Parameters

  • poll_interval (float) – polling period in seconds to check for the status

  • query_ids (list[str]) – List of Query ids to run and poll for the status

  • snowflake_conn_id (str) – Reference to Snowflake connection id

  • token_life_time (datetime.timedelta) – lifetime of the JWT Token in timedelta

  • token_renewal_delta (datetime.timedelta) – Renewal time of the JWT Token in timedelta

serialize()[source]

Serializes SnowflakeSqlApiTrigger arguments and classpath.

async run()[source]

Wait for the query the snowflake query to complete.

async get_query_status(query_id)[source]

Async function to check whether the query statement submitted via SQL API is still running state and returns True if it is still running else return False.

Was this entry helpful?