class_docstr: Trigger with params to run the task when the ADF Pipeline is running.
  
  :param run_id: The pipeline run identifier.
  :param azure_data_factory_conn_id: The connection identifier for connecting to Azure Data Factory.
  :param poke_interval:  polling period in seconds to check for the status
  :param resource_group_name: The resource group name.
  :param factory_name: The data factory name.
class_docstr_tok: ["Trigger","with","params","to","run","the","task","when","the","ADF","Pipeline","is","running",".",":","param","run_id",":","The","pipeline","run","identifier",".",":","param","azure_data_factory_conn_id",":","The","connection","identifier","for","connecting","to","Azure","Data","Factory",".",":","param","poke_interval",":","polling","period","in","seconds","to","check","for","the","status",":","param","resource_group_name",":","The","resource","group","name",".",":","param","factory_name",":","The","data","factory","name","."]
docstr: Serializes ADFPipelineRunStatusSensorTrigger arguments and classpath.
docstr_tok: ["Serializes","ADFPipelineRunStatusSensorTrigger","arguments","and","classpath","."]
code: def serialize(self) -> tuple[str, dict[str, Any]]:
      """Serializes ADFPipelineRunStatusSensorTrigger arguments and classpath."""
      return (
          "airflow.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger",
          {
              "run_id": self.run_id,
              "azure_data_factory_conn_id": self.azure_data_factory_conn_id,
              "resource_group_name": self.resource_group_name,
              "factory_name": self.factory_name,
              "poke_interval": self.poke_interval,
          },
      )
  
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 ADFPipelineRunStatusSensorTrigger obj's underlying member method code with example usage: obj.serialize() and returns: str,  dict