我将dag id存储在python代码中的变量中。我想知道那个dag是否处于运行状态。我如何才能知道使用REST API?
发布于 2020-11-05 22:07:46
您可以使用此端点:
GET /api/experimental/dags/<DAG_ID>/dag_runs例如,要获取所有dag运行及其状态的列表,请查看我的输出:
http://localhost:8080/api/experimental/dags/my_dag_id/dag_runs
[
    {
        "dag_id": "my_dag_id",
        "dag_run_url": "/admin/airflow/graph?dag_id=my_dag_id&execution_date=2020-11-04+00%3A00%3A00%2B00%3A00",
        "execution_date": "2020-11-04T00:00:00+00:00",
        "id": 62,
        "run_id": "scheduled__2020-11-04T00:00:00+00:00",
        "start_date": "2020-11-05T14:05:36.902918+00:00",
        "state": "running"
    },
    {
        "dag_id": "my_dag_id",
        "dag_run_url": "/admin/airflow/graph?dag_id=my_dag_id&execution_date=2020-11-05+14%3A05%3A32.496146%2B00%3A00",
        "execution_date": "2020-11-05T14:05:32.496146+00:00",
        "id": 61,
        "run_id": "manual__2020-11-05T14:05:32.496146+00:00",
        "start_date": "2020-11-05T14:05:32.505224+00:00",
        "state": "running"
    }
]https://stackoverflow.com/questions/64698375
复制相似问题