Airflow dag 文件不是 运行

Question

我对气流很陌生。

我每 10 分钟安排一个 dag 文件 运行。我的默认参数如下。

args = {
    'owner': 'crv',
    'start_date': datetime(2021, 1, 1),
}

dag = DAG(
    dag_id='score',
    default_args=args,
    schedule_interval='*/10 * * * *',
    tags=['example']
)

我 运行 使用以下命令在后台运行气流调度程序。

airflow scheduler &

在我执行 airflow scheduler & 命令后，dag 文件正确执行，并且 运行 进程按计划进行。因此，我从终端退出（我在服务器上 运行ning dag 文件）。过了一会儿，我登录到服务器，发现 dag 文件没有按照计划 运行ning，并且在我退出终端后它停止了 运行ning 进程。然后我杀死当前 运行ning 调度程序并重新启动它。在该 dag 文件正常工作之后。但是当我从终端退出时，它会再次根据计划停止 运行 进程。

我检查了这个答案中的所有要点

我的任务实例详情如下

任何人都可以帮助解决我的问题。谢谢。

Answer 1

您需要 运行 守护程序模式下的调度程序。使用 airflow scheduler -D.

您可以在 documentation

中阅读更多可选参数