class_docstr: Trigger when the Azure data factory pipeline job finishes.
  
  When wait_for_termination is set to False, it triggers immediately with success status.
  
  :param run_id: Run id of a Azure data pipeline run job.
  :param azure_data_factory_conn_id: The connection identifier for connecting to Azure Data Factory.
  :param end_time: Time in seconds when triggers will timeout.
  :param resource_group_name: The resource group name.
  :param factory_name: The data factory name.
  :param wait_for_termination: Flag to wait on a pipeline run's termination.
  :param check_interval: Time in seconds to check on a pipeline run's status.
class_docstr_tok: ["Trigger","when","the","Azure","data","factory","pipeline","job","finishes",".","When","wait_for_termination","is","set","to","False",",","it","triggers","immediately","with","success","status",".",":","param","run_id",":","Run","id","of","a","Azure","data","pipeline","run","job",".",":","param","azure_data_factory_conn_id",":","The","connection","identifier","for","connecting","to","Azure","Data","Factory",".",":","param","end_time",":","Time","in","seconds","when","triggers","will","timeout",".",":","param","resource_group_name",":","The","resource","group","name",".",":","param","factory_name",":","The","data","factory","name",".",":","param","wait_for_termination",":","Flag","to","wait","on","a","pipeline","run","'s","termination",".",":","param","check_interval",":","Time","in","seconds","to","check","on","a","pipeline","run","'s","status","."]
docstr: Serializes AzureDataFactoryTrigger arguments and classpath.
docstr_tok: ["Serializes","AzureDataFactoryTrigger","arguments","and","classpath","."]
code: def serialize(self) -> tuple[str, dict[str, Any]]:
      """Serializes AzureDataFactoryTrigger arguments and classpath."""
      return (
          "airflow.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger",
          {
              "azure_data_factory_conn_id": self.azure_data_factory_conn_id,
              "check_interval": self.check_interval,
              "run_id": self.run_id,
              "wait_for_termination": self.wait_for_termination,
              "resource_group_name": self.resource_group_name,
              "factory_name": self.factory_name,
              "end_time": self.end_time,
          },
      )
  
file_path: airflow/airflow/providers/microsoft/azure/triggers/data_factory.py
imports: from __future__ import annotations
  import asyncio
  import time
  from typing import Any, AsyncIterator
  from azure.core.exceptions import ServiceRequestError
  from airflow.providers.microsoft.azure.hooks.data_factory import AzureDataFactoryAsyncHook, AzureDataFactoryPipelineRunStatus
  from airflow.triggers.base import BaseTrigger, TriggerEvent
label_desc: Use image node_id 2 for calling the AzureDataFactoryTrigger obj's underlying member method code with example usage: obj.serialize() and returns: str,  dict