astronomer.providers.amazon.aws.triggers.redshift_sql

Module Contents

Classes

RedshiftSQLTrigger

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

serialize()[source]

Serializes RedshiftSQLTrigger arguments and classpath.

async run()[source]

Make async connection and execute query using the Amazon Redshift Data API.