在TaskGroup中使用On_failure_callback（任务失败回调）代替On_callback_failure。

在Airflow v2.0中，On_failure_callback已经替换了On_callback_failure。这意味着如果您正在使用TaskGroup（任务组）设置，您需要使用On_failure_callback来代替On_callback_failure。下面是使用On_failure_callback的示例代码：

from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from airflow.operators.dummy_operator import DummyOperator
from airflow.operators.python_operator import PythonOperator
from airflow.utils.task_group import TaskGroup

def on_failure_callback(context):
    print('This is a failure callback!')
    # Insert your own failure notification logic here

with DAG(dag_id='example_dag', start_date=datetime(2022, 1, 1), schedule_interval=None) as dag:

    start_task = DummyOperator(task_id='start_task')

    with TaskGroup(group_id='task_group', on_failure_callback=on_failure_callback) as task_group:

        bash_task = BashOperator(
            task_id='bash_task',
            bash_command='echo "Hello, Airflow!"'
        )

        python_task = PythonOperator(
            task_id='python_task',
            python_callable=lambda: print('Hello, Airflow!')
        )

    end_task = DummyOperator(task_id='end_task')

    start_task >> task_group >> end_task

在此示例中，我们定义了一个名为on_failure_callback（任务失败回调）的回调函数，并将其设置为TaskGroup（任务组）中的on_failure_callback参数。当TaskGroup中的任何任务失败时，都会调用该回调函数。请注意，您可以根据需要调整回调函数中的逻辑以适应您的具体用例。

通过替换旧的On_callback_failure回调函数，使用新的On_failure_callback回调函数进行错误处理，您可以更好地管理Airflow的工作流程和任务组中的任务。