astronomer.providers.microsoft.azure.sensors.data_factory

Module Contents

Classes

AzureDataFactoryPipelineRunStatusSensorAsync

Checks the status of a pipeline run.
class astronomer.providers.microsoft.azure.sensors.data_factory.AzureDataFactoryPipelineRunStatusSensorAsync(*, poll_interval=5, **kwargs)[source]

Bases: airflow.providers.microsoft.azure.sensors.data_factory.AzureDataFactoryPipelineRunStatusSensor

Checks the status of a pipeline run.

Parameters:

  • azure_data_factory_conn_id – The connection identifier for connecting to Azure Data Factory.

  • run_id – The pipeline run identifier.

  • resource_group_name – The resource group name.

  • factory_name – The data factory name.

  • poll_interval (float) – polling period in seconds to check for the status

execute(context)[source]

Defers trigger class to poll for state of the job run until it reaches a failure state or success state

execute_complete(context, event)[source]

Callback for when the trigger fires - returns immediately. Relies on trigger to throw an exception, otherwise it assumes execution was successful.