astronomer.providers.snowflake.triggers.snowflake_trigger
¶
Module Contents¶
Classes¶
Snowflake Trigger inherits from the BaseTrigger,it is fired as |
|
SnowflakeSqlApi Trigger inherits from the BaseTrigger,it is fired as |
Functions¶
|
Create and return SnowflakeHookAsync. |
- astronomer.providers.snowflake.triggers.snowflake_trigger.get_db_hook(snowflake_conn_id)[source]¶
Create and return SnowflakeHookAsync. :return: a SnowflakeHookAsync instance.
- class astronomer.providers.snowflake.triggers.snowflake_trigger.SnowflakeTrigger(task_id, poll_interval, query_ids, snowflake_conn_id)[source]¶
Bases:
airflow.triggers.base.BaseTrigger
Snowflake Trigger inherits from the BaseTrigger,it is fired as deferred class with params to run the task in trigger worker and fetch the status for the query ids passed
- Parameters:
task_id (str) – Reference to task id of the Dag
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
- class astronomer.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
SnowflakeSqlApi Trigger inherits from the BaseTrigger,it is fired as deferred class with params to run the task in trigger worker and fetch the status for the query ids passed
- Parameters:
task_id – Reference to task id of the Dag
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