airflow.providers.microsoft.azure.sensors.analysis_services

Classes

AzureAnalysisServicesSensor

Wait for an Azure Analysis Services model refresh to finish.

Module Contents

class airflow.providers.microsoft.azure.sensors.analysis_services.AzureAnalysisServicesSensor(*, server_name, database, refresh_id, azure_analysis_services_conn_id=AzureAnalysisServicesHook.default_conn_name, request_timeout=60, **kwargs)[source]

Bases: airflow.providers.common.compat.sdk.BaseSensorOperator

Wait for an Azure Analysis Services model refresh to finish.

The sensor always runs deferred: status polling happens in the triggerer, so no worker slot is held while the model is refreshing. A triggerer must therefore be running in the deployment.

See also

For more information, see Wait with a sensor.

Parameters:
  • server_name (str) – The Analysis Services server name.

  • database (str) – The model database name.

  • refresh_id (str) – The refresh operation ID to monitor.

  • azure_analysis_services_conn_id (str) – The Azure Analysis Services connection ID.

  • request_timeout (float) – Timeout in seconds for each HTTP request.

template_fields: collections.abc.Sequence[str] = ('azure_analysis_services_conn_id', 'server_name', 'database', 'refresh_id')[source]
ui_color = '#0078d4'[source]
ui_fgcolor = '#ffffff'[source]
server_name[source]
database[source]
refresh_id[source]
azure_analysis_services_conn_id = 'azure_analysis_services_default'[source]
request_timeout = 60[source]
execute(context)[source]

Defer status polling to the triggerer.

execute_complete(context, event)[source]

Validate the terminal trigger event.

Was this entry helpful?