diff --git a/providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/data_factory.py b/providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/data_factory.py
index c49b066ea2662..fc0d23c6a9381 100644
--- a/providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/data_factory.py
+++ b/providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/data_factory.py
@@ -1214,7 +1214,4 @@ async def cancel_pipeline_run(
         :param config: Extra parameters for the ADF client.
         """
         client = await self.get_async_conn()
-        try:
-            await client.pipeline_runs.cancel(resource_group_name, factory_name, run_id)
-        except Exception as e:
-            raise AirflowException(e)
+        await client.pipeline_runs.cancel(resource_group_name, factory_name, run_id)
diff --git a/providers/microsoft/azure/src/airflow/providers/microsoft/azure/triggers/data_factory.py b/providers/microsoft/azure/src/airflow/providers/microsoft/azure/triggers/data_factory.py
index 5e275a66762ef..f047fe23241d8 100644
--- a/providers/microsoft/azure/src/airflow/providers/microsoft/azure/triggers/data_factory.py
+++ b/providers/microsoft/azure/src/airflow/providers/microsoft/azure/triggers/data_factory.py
@@ -229,14 +229,15 @@ async def run(self) -> AsyncIterator[TriggerEvent]:
                     }
                 )
         except Exception as e:
+            self.log.exception(e)
             if self.run_id:
                 try:
+                    self.log.info("Cancelling pipeline run %s", self.run_id)
                     await hook.cancel_pipeline_run(
                         run_id=self.run_id,
                         resource_group_name=self.resource_group_name,
                         factory_name=self.factory_name,
                     )
-                    self.log.info("Unexpected error %s caught. Cancel pipeline run %s", e, self.run_id)
-                except Exception as err:
-                    yield TriggerEvent({"status": "error", "message": str(err), "run_id": self.run_id})
+                except Exception:
+                    self.log.exception("Failed to cancel pipeline run %s", self.run_id)
             yield TriggerEvent({"status": "error", "message": str(e), "run_id": self.run_id})