:py:mod:`astronomer.providers.microsoft.azure.sensors.data_factory`
===================================================================

.. py:module:: astronomer.providers.microsoft.azure.sensors.data_factory


Module Contents
---------------

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.microsoft.azure.sensors.data_factory.AzureDataFactoryPipelineRunStatusSensorAsync




.. py:class:: AzureDataFactoryPipelineRunStatusSensorAsync(*, poll_interval = 5, **kwargs)

   Bases: :py:obj:`airflow.providers.microsoft.azure.sensors.data_factory.AzureDataFactoryPipelineRunStatusSensor`

   Checks the status of a pipeline run.

   :param azure_data_factory_conn_id: The connection identifier for connecting to Azure Data Factory.
   :param run_id: The pipeline run identifier.
   :param resource_group_name: The resource group name.
   :param factory_name: The data factory name.
   :param poll_interval: polling period in seconds to check for the status

   .. py:method:: execute(context)

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


   .. py:method:: execute_complete(context, event)

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