当我把我的DAG装进气流中时,它显示一切都很好。一旦我为我的DAG触发了运行,它将创建一个run,并在不运行我的任务的情况下切换到成功。and服务器和调度程序都在运行,日志中没有任何内容。如果我使用airflow test update_dags work 2019-01-01直接运行我的任务,它就运行得很好。这是我的DAG:from airflow.operator
我正在使用气流稳定舵图和Kubernetes Executor,新的pod正在为dag调度,但它与dag_id的故障无法找到问题。我正在使用git-sync来获取dags。, in get_dagairflow.exceptions.AirflowException: dag_id could not配置:
AIRFLOW__KUBERNETES__D
谁能解释一下为什么Airflow的ExternalTaskSensor在日程安排上正常工作,而不是在前端触发时工作?我尝试了几个版本,结果总是一样的。任务在up_fro_reschedule上停止。2020-03-08 22:25:25,363] {taskinstance.py:934} INFO - Exporting the following env vars:AIRFLOW_CTX_DAG_ID=example_external_task_marker
在git中,我们可以运行以下命令:git pullgit rebase master
它将在mybranch上进行提交,并将其重基到更新的主服务器上。ie:对master和mybranch的提交进行线性化。我知道mercurial有一个重基扩展,但是它看起来确实是基于修订编号而不是书签名的。有什么方法可以使它与书签名称一起工作吗?