airflow.providers.amazon.aws.sensors.quicksight

Module Contents

Classes

QuickSightSensor

Watches for the status of an Amazon QuickSight Ingestion.
class airflow.providers.amazon.aws.sensors.quicksight.QuickSightSensor(*, data_set_id, ingestion_id, aws_conn_id='aws_default', **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Watches for the status of an Amazon QuickSight Ingestion.

See also

For more information on how to use this sensor, take a look at the guide: Amazon QuickSight ingestion sensor

Parameters

  • data_set_id (str) -- ID of the dataset used in the ingestion.

  • ingestion_id (str) -- ID for the ingestion.

  • aws_conn_id (str) -- The Airflow connection used for AWS credentials. (templated) If this is None or empty then the default boto3 behaviour is used. If running Airflow in a distributed manner and aws_conn_id is None or empty, then the default boto3 configuration would be used (and must be maintained on each worker node).

template_fields :Sequence[str] = ['data_set_id', 'ingestion_id', 'aws_conn_id'][source]
poke(context)[source]

Pokes until the QuickSight Ingestion has successfully finished.

Parameters

context (airflow.utils.context.Context) -- The task context during execution.

Returns

True if it COMPLETED and False if not.

Return type

bool

get_quicksight_hook()[source]
get_sts_hook()[source]

Was this entry helpful?