:py:mod:`astronomer.providers.microsoft.azure.triggers.data_factory` ==================================================================== .. py:module:: astronomer.providers.microsoft.azure.triggers.data_factory Module Contents --------------- Classes ~~~~~~~ .. autoapisummary:: astronomer.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger astronomer.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger .. py:class:: ADFPipelineRunStatusSensorTrigger(run_id, azure_data_factory_conn_id, poke_interval, resource_group_name, factory_name) Bases: :py:obj:`airflow.triggers.base.BaseTrigger` This class is deprecated and will be removed in 2.0.0. Use :class: `~airflow.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger` instead. .. py:method:: serialize() Serializes ADFPipelineRunStatusSensorTrigger arguments and classpath. .. py:method:: run() :async: Make async connection to Azure Data Factory, polls for the pipeline run status .. py:class:: AzureDataFactoryTrigger(run_id, azure_data_factory_conn_id, end_time, resource_group_name, factory_name, wait_for_termination = True, check_interval = 60) Bases: :py:obj:`airflow.triggers.base.BaseTrigger` This class is deprecated and will be removed in 2.0.0. Use :class: `~airflow.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger` instead. .. py:attribute:: QUEUED :value: 'Queued' .. py:attribute:: IN_PROGRESS :value: 'InProgress' .. py:attribute:: SUCCEEDED :value: 'Succeeded' .. py:attribute:: FAILED :value: 'Failed' .. py:attribute:: CANCELING :value: 'Canceling' .. py:attribute:: CANCELLED :value: 'Cancelled' .. py:attribute:: INTERMEDIATE_STATES :type: List[str] .. py:attribute:: FAILURE_STATES :type: List[str] .. py:attribute:: SUCCESS_STATES :type: List[str] .. py:attribute:: TERMINAL_STATUSES :type: List[str] .. py:method:: serialize() Serializes AzureDataFactoryTrigger arguments and classpath. .. py:method:: run() :async: Make async connection to Azure Data Factory, polls for the pipeline run status