我想创建一个dag,它每小时运行一次,我们有一个导入和清理文件的cleanData进程,然后是一个storedata进程,它每天在上午8点和下午6点向我们发送两次报告如何在dag中包含时间?import pandas as pdfrom datetime import datetime
from airflow.operators.python_
;max_threads为10。我的问题是,当我创建一个每天都要运行的守护进程时,一切都很好,但是当我创建一个dag,它将在周一和周三上午10点运行时,气流不会运行它。有人知道我做错了什么吗?我应该怎么做才能解决这个问题?,运行良好且正确:from airflow import DAG
from airflow.operators.bash_operator impo
我正在使用Astronomer运行Airflow v1.10.10。每个dag运行(每天)可以有不同数量的任务。此任务数将由给定dag运行(即当天)的数据库表中的行数定义。我将在dag文件中运行一个查询,并创建一个如下列表:然后,我将根据列表的大小创建任务:
for i in range(1, len(list)