【问题标题】:Airflow dag file is not running气流 dag 文件未运行
【发布时间】:2021-05-03 17:51:19
【问题描述】:

我对气流很陌生。

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

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 文件正确执行并按计划运行进程。所以,我从终端退出(我在服务器上运行 dag 文件)。过了一会儿,我登录到服务器,发现 dag 文件没有按计划运行,并且在我退出终端后停止运行进程。然后我杀死当前正在运行的调度程序并重新启动它。之后 dag 文件正常工作。但是当我从终端退出时,它会再次按照计划停止运行进程。

我检查了这个答案https://stackoverflow.com/a/49047832/7909792中的所有要点

我的任务实例详情如下

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

【问题讨论】:

    标签: airflow airflow-scheduler


    【解决方案1】:

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

    您可以在documentation 中了解更多可选参数

    【讨论】:

    • 感谢您的回答。这是有效的
    猜你喜欢
    • 2022-11-02
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2019-01-08
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多