astronomer.providers.amazon.aws.triggers.redshift_sql
¶
Module Contents¶
Classes¶
RedshiftSQLTrigger is fired as deferred class with params to run the task in trigger worker |
- class astronomer.providers.amazon.aws.triggers.redshift_sql.RedshiftSQLTrigger(task_id, polling_period_seconds, aws_conn_id, query_ids)[source]¶
Bases:
airflow.triggers.base.BaseTrigger
RedshiftSQLTrigger is fired as deferred class with params to run the task in trigger worker
- Parameters:
task_id (str) – Reference to task id of the Dag
polling_period_seconds (float) – polling period in seconds to check for the status
aws_conn_id (str) – Reference to AWS connection id for redshift
query_ids (List[str]) – list of Query ids to run and poll for the status