class_docstr: 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 deferrable: Run sensor in the deferrable mode.
docstr: Callback for when the trigger fires - returns immediately.
  
  Relies on trigger to throw an exception, otherwise it assumes execution was successful.
docstr_tok: ["Callback","for","when","the","trigger","fires","-","returns","immediately",".","Relies","on","trigger","to","throw","an","exception",",","otherwise","it","assumes","execution","was","successful","."]
code: def execute_complete(
      self, context: Context, event: dict[str, str]
  ) -> None:
      """
      Callback for when the trigger fires - returns immediately.
  
      Relies on trigger to throw an exception, otherwise it assumes execution was successful.
      """
      if event:
          if event["status"] == "error":
              # TODO: remove this if check when min_airflow_version is set to higher than 2.7.1
              if self.soft_fail:
                  raise AirflowSkipException(event["message"])
              raise AirflowException(event["message"])
          self.log.info(event["message"])
      return None
  
file_path: airflow/airflow/providers/microsoft/azure/sensors/data_factory.py
imports: from __future__ import annotations
  from datetime import timedelta
  from functools import cached_property
  from typing import TYPE_CHECKING, Sequence
  from airflow.configuration import conf
  from airflow.exceptions import AirflowException, AirflowSkipException
  from airflow.providers.microsoft.azure.hooks.data_factory import AzureDataFactoryHook, AzureDataFactoryPipelineRunException, AzureDataFactoryPipelineRunStatus
  from airflow.providers.microsoft.azure.triggers.data_factory import ADFPipelineRunStatusSensorTrigger
  from airflow.sensors.base import BaseSensorOperator
label_desc: Use image node_id 5 for calling the AzureDataFactoryPipelineRunStatusSensor obj's underlying member method code with example usage: obj.execute_complete(context, event) and returns: None