在DAG的最后一项任务中，经过多次执行，气流堆积

我有一个由7个任务组成的DAG。我已经执行了很多次，但最近它陷入了最后一个任务，这是一个非常简单的python操作符如下:

def send_email(warnings):
    warnings = ast.literal_eval(warnings)
    warnings_list = '\n'.join(warnings)

    email_message =f"""Good morning, the past week there were some performance issues, which were the following ones:

            \n {warnings_list}

            Have a nice day!"""

    send_email_smtp(to = 'email@email.com',
              subject = 'Warning',
              html_content = email_message)

send_email_task = PythonOperator(
            task_id = 'send_email_task',
            op_args = ["{{ task_instance.xcom_pull(task_ids='performance_comparison') }}"],
            python_callable = send_email)

如果我输入任务实例的细节，我看到以下: 任务实例状态:任务处于“正在运行”状态，这不是有效的执行状态。必须清除该任务才能运行。 任务实例没有运行:任务已经运行，它开始于2019-12-17 18:00:20.747617+00:00。 我已经完成了任务，并多次被标记为失败/成功。我甚至稍微修改了DAG的代码来强制刷新，但它仍然不能工作。正如我几小时前说过的，它已经工作了好几次。 你知道发生了什么事吗? 预先非常感谢你 问题来源StackOverflow 地址：/questions/59379807/airflow-get-stacked-in-last-task-of-dag-after-several-executions