回答情况：
提问时间：
问题标签：
我创建我的气流DAG如下：with DAG(...) as dag:
# Code that will use the dag variable我猜这样，在调度程序执行代码块之后，DAG实例将被销毁，但是这样做有真正的好处吗？我找不到任何关于这个的文件。
浏览 3修改于2021-10-13得票数 3
回答已采纳
我正在使用TriggerDagRunOperator，以便一个控制器DAG可以触发一个目标DAG。但是，一旦控制器DAG触发了目标DAG，目标DAG就会切换到"running"，但它的任何任务都不会被调度。我希望一旦控制器DAG触发目标DAG，就安排目标DAG的任务。# Controller DAG's callable
def conditionally_trigger(context, dag
浏览 10修改于2019-06-11得票数 0
当我尝试删除Web UI中的dag时，结果是： ? Dag id zhihu_qr_dag is still in DagBag. Remove the DAG file first.但实际上dag是一个无效的dag，我无法进入dag页面。当我单击dag时，它显示： DAG "zhihu_qr_dag" seems to be missing. 我该怎么处理呢？提前感谢！
浏览 72提问于2019-10-14得票数 2
回答已采纳
我们运行的是Airflow v1.9.0，其中一个DAG出现了问题。这个SSHOperator操作符DAG (称为匹配)从06***开始，通常在一小时内完成。不幸的是，当这种情况发生时，DAG会阻止我们的其他DAG启动，直到它完成。它是这7小时内唯一运行的DAG。这不是正常行为，也不是我们的其他DAGS (它们继续运行，其他DAGS将启动)。= dag)
以下是我查看airflow数据库时的查询结果。之后的此DAG计划于10:40启动。task_id: Task1 <e
浏览 1修改于2018-05-11得票数 0
我有下面的“主”DAG。我想根据底部的下游部分调用关联的DAG。 然而，发生的情况是，第一个DAG被调用了四次，而其他三个DAG运行了一微秒(不足以实际执行)，所有东西都返回绿色。= models.DAG( default_args=args, trigger_dag_id='
浏览 25修改于2020-06-20得票数 0
回答已采纳
1回答
我想动态地从另一个dag中调用DAG，例如，当操作符将触发这个父DAG时，它应该会生成新的DAG。我看不出原因。= DAG("generated_dag", catchup=Falsepython_callable=do_something,
dag=<em
浏览 8提问于2022-03-24得票数 0
sqlalchemy.exc.IntegrityError: (_mysql_exceptions.IntegrityError) (1062, "Duplicate entry 'external_dag-2021-11-01 00:00:00.000000' for key 'dag_id'"x = TriggerDagRunOpe
浏览 3提问于2021-11-01得票数 1
回答已采纳
1回答
我有一个控制程序，它会触发另外两个dag。这两个dags应该按顺序运行，而不是并行运行。我的问题是，触发的DAG确实得到一个特定的execution_date (特定到秒，而不是00:00分和秒)。我的问题：
( a)由控制器DAG触发的依赖DAG的execution_date (然后可以作为参数传递给传感器)。或
b)依赖DAG的executi
浏览 0提问于2018-07-17得票数 1
DAG B有时间表'*/5 ** *‘。
但是，DAG只应在DAG完成当天之后才开始运行该天。编辑：说DAG是我的ETL。DAG有一些任务可以查询我的数据库，并要求这些数据是最新的.DAG全天运行，但只有ETL完成后才能运行。例如，我可以看到使用ShortCircuitOperator，并且条件是“今天运行的DAG已经完成”。但我怎么能写出这个条件呢？
浏览 0修改于2018-07-02得票数 2
非常喜欢气流工作流调度程序，但是遇到了运行简单DAG："{jobs.py:538} error - Dag运行为DAG: TEST_SCHEDULER_DAG时陷入僵局“的错误。我获得死锁错误的DAG是：from airflow.operators import BashOperator
from datetime import= DAG(dag_id='TEST_SCHEDULER
浏览 2修改于2016-11-30得票数 2
考虑到一个将值推送到xcom的父dag，如何从子dag检索dag？我尝试过的： #parent_dag.py
CHILD_DAG_NAME = "MyChildDag"
subdag=Sub_Dag1
浏览 39提问于2019-02-20得票数 5
我在codebuild中的容器中运行了一个气流，目前它执行所有的东西，但在触发DAG的部分它失败了。scheduler > ~/scheduler.log 2>&1 & - airflow trigger_dag----------------------------------------------------------------------------------但它不执行
浏览 1修改于2018-07-09得票数 1
我想知道您是否可以在DAG运行中轻松、动态地生成DAG，例如：
DAG的TriggerDagRunOperator上一个DAG任务的ExternalTaskSensor。
浏览 0提问于2021-11-16得票数 0
我有一个很大的DAG，大约有400个任务，从8:00开始，运行大约2.5小时。没有其他全局配置来限制运行任务的数量，其他较小的dags通常并行运行。
浏览 14提问于2022-02-18得票数 1
我正在尝试创建一个dag，它有两个操作符，它们是动态创建的，这取决于json配置文件拥有的“管道”的数量。该文件存储在变量dag_datafusion_args中。我使用的是编写器，当我将dag放入存储桶中时，它会出现在when服务器ui上，但当我单击查看dag时，会出现以下消息：“dag "dag_lucas4”似乎缺失。=return_datafusion_config_file('med')with DAG('
浏览 21修改于2021-01-12得票数 0
1回答
import PythonOperator
schedule, schedule_interval=schedule,',
python_callable=hell
浏览 16提问于2021-02-20得票数 2
File "/home/airflow/.local/lib/python3.6/site-packages/airflow/models/dagbag.py", line 249, in _add_dag_from_dbraise SerializedDagNotFound(f"DAG '{dag_id}' not found in serialized_dag table"
浏览 3修改于2022-05-11得票数 0
2回答
def create_dag(project, version): dag = DAG(dag_id, default_args=default_args, schedule_interval='*/10 * * * *', catchup=False)
print('creating DAG ' + dag_id)t1 =
浏览 0修改于2018-10-29得票数 6
回答已采纳
1回答
我有两个Dag Dag 1和Dag 2 任务A、B和C在Dag 1中任务D、E和F在Dag 2中 如何实现第三个Dag来利用这些任务？我想让DAG3使用任务A，然后是任务E，然后是任务C，而不需要重写函数
浏览 18提问于2021-08-25得票数 1
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号