:py:mod:`astronomer.providers.microsoft.azure.hooks.data_factory` ================================================================= .. py:module:: astronomer.providers.microsoft.azure.hooks.data_factory Module Contents --------------- Classes ~~~~~~~ .. autoapisummary:: astronomer.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHookAsync Attributes ~~~~~~~~~~ .. autoapisummary:: astronomer.providers.microsoft.azure.hooks.data_factory.Credentials .. py:data:: Credentials .. py:class:: AzureDataFactoryHookAsync(azure_data_factory_conn_id) Bases: :py:obj:`airflow.providers.microsoft.azure.hooks.data_factory.AzureDataFactoryHook` An Async Hook connects to Azure DataFactory to perform pipeline operations :param azure_data_factory_conn_id: The :ref:`Azure Data Factory connection id`. .. py:method:: get_async_conn(self) :async: Get async connection and connect to azure data factory .. py:method:: get_pipeline_run(self, run_id, resource_group_name = None, factory_name = None, **config) :async: Connects to Azure Data Factory asynchronously to get the pipeline run details by run id :param run_id: The pipeline run identifier. :param resource_group_name: The resource group name. :param factory_name: The factory name. .. py:method:: get_adf_pipeline_run_status(self, run_id, resource_group_name = None, factory_name = None) :async: Connects to Azure Data Factory asynchronously and gets the pipeline status by run_id :param run_id: The pipeline run identifier. :param resource_group_name: The resource group name. :param factory_name: The factory name.