airflow.providers.snowflake.triggers.snowflake_trigger
¶
Module Contents¶
Classes¶
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