气流休息API Python SDK
airflow-restapi-sdk的Python项目详细描述
气流重启-SDK
fromairflow_restapi_sdkimportClient,Stateclient=Client('http://localhost:8080')# 触发DAGclient.dag.trigger('test_dag',conf={'k':'v'})# {# "execution_date": "2020-08-20T07:51:36+00:00",# "message": "Created <DagRun test_dag @ 2020-08-20 07:51:36+00:00: manual__2020-08-20T07:51:36+00:00, externally triggered: True>",# "run_id": "manual__2020-08-20T07:51:36+00:00"# }# 查看DAG运行状态client.dag.state('test_dag','2020-08-20T07:51:36+00:00')# {'state': 'failed'}# 触发DAG并阻塞，直到成功或失败status=client.dag.trigger_join('test_dag',conf={'k':'v'},timeout=300)print(status)# {'state': 'failed'}
- 项目
标签：
欢迎加入QQ群-->： 979659372
