要实现任务在失败后仍保持运行状态，可以使用Airflow中的on_failure_callback回调函数来处理任务失败的情况。该回调函数会在任务失败时被触发，并可以执行一些自定义的操作。

以下是一个使用on_failure_callback回调函数的示例代码：

from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from airflow.utils.dates import days_ago

def my_task():
    # 任务逻辑代码
    # ...

def handle_failure(context):
    # 任务失败后的处理代码
    # 可以在这里添加一些自定义的操作，比如发送通知、重试等

default_args = {
    'owner': 'airflow',
    'start_date': days_ago(1),
    'on_failure_callback': handle_failure  # 指定任务失败时的回调函数
}

with DAG('my_dag', default_args=default_args, schedule_interval='@daily') as dag:
    task1 = PythonOperator(
        task_id='my_task',
        python_callable=my_task
    )

在上述代码中，handle_failure函数是一个自定义的回调函数，用于处理任务失败的情况。可以在该函数中添加一些逻辑来处理任务失败的情况，比如发送通知、重试等。

然后，将handle_failure函数指定为default_args中的on_failure_callback参数，这样当任务失败时，Airflow会自动调用该回调函数。

请注意，on_failure_callback回调函数是全局生效的，即对于该DAG中的所有任务都会生效。如果需要对某个特定的任务使用不同的回调函数，可以在任务的参数中单独指定。