This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 49de9113093 Fix callbacks docs (#50377)
49de9113093 is described below
commit 49de91130931d243732ef718b90c707a984070e4
Author: Kaxil Naik <[email protected]>
AuthorDate: Fri May 9 12:33:06 2025 +0530
Fix callbacks docs (#50377)
---
.../administration-and-deployment/logging-monitoring/callbacks.rst | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/airflow-core/docs/administration-and-deployment/logging-monitoring/callbacks.rst
b/airflow-core/docs/administration-and-deployment/logging-monitoring/callbacks.rst
index 377d06579cf..a6c6c7d6210 100644
---
a/airflow-core/docs/administration-and-deployment/logging-monitoring/callbacks.rst
+++
b/airflow-core/docs/administration-and-deployment/logging-monitoring/callbacks.rst
@@ -83,13 +83,13 @@ In the following example, failures in any task call the
``task_failure_alert`` f
start_date=pendulum.datetime(2021, 1, 1, tz="UTC"),
dagrun_timeout=datetime.timedelta(minutes=60),
catchup=False,
- on_success_callback=None,
- on_failure_callback=task_failure_alert,
+ on_success_callback=dag_success_alert,
+ on_failure_callback=None,
tags=["example"],
):
task1 = EmptyOperator(task_id="task1")
task2 = EmptyOperator(task_id="task2")
- task3 = EmptyOperator(task_id="task3",
on_success_callback=[dag_success_alert])
+ task3 = EmptyOperator(task_id="task3",
on_failure_callback=[task_failure_alert])
task1 >> task2 >> task3
.. note::
