小编Rav*_*avi的帖子

当我们尝试使用 python 3.6.8 版本执行时，出现以下模块错误

from wtforms.compat import string_types, text_type
ModuleNotFoundError: No module named 'wtforms.compat'

当我尝试安装或升级 wtforms 时仍然显示相同的错误

任何人都可以建议吗

我们有 100 个 dags，其前缀为“dag_EDW_HC_*”。我们有下面的命令来暂停 dag

Command: airflow pause dag_id

有什么方法可以一次性暂停所有 100 个 dags“dag_EDW_HC_*”..（以 Python 编程或任何其他方式）..？

我们有以下命令，我们可以清除失败的任务并一次尝试重新运行它们

airflow clear [-s START_DATE] [-e END_DATE] --only_failed dag_id

有什么方法可以从所有 dags 中获取所有失败任务的信息并将其导出到文件（excel 或文本）中

我试过下面的代码，但我仍然遇到问题

from airflow.models DagModel

def get_latest_execution_date(**kwargs):

session = airflow.settings.Session()

f = open("/home/Insurance/InsuranceDagsTimestamp.txt","w+")

try:
    Insurance_last_dag_run = session.query(DagModel)
    for Insdgrun in Insurance_last_dag_run:
        if Insdgrun is None: 
            f.write(Insdgrun.dag_id+",9999-12-31"+"\n")
        else:
            f.write(Insdgrun.dag_id+","+ Insdgrun.execution_date+"\n")
except:
    session.rollback()
finally:
    session.close()

t1 = PythonOperator(
    task_id='records',
    provide_context=True,
    python_callable=get_latest_execution_date,
    dag=dag)

有什么方法可以修复和获取最新的 dag 运行时信息