- 当前热门话题：
Python dagrun
-
本站为您提供最新、最全的dagrun的Python教程、文档、代码、资源等相关内容，Python中文网技术交流社区同时还提供学习资源下载，
如：电子书、IDE编辑器软件、编程视频、代码规范标准、WEB开发、GUI、科学计算与人工智能等相关内容。
本文网址：https://cnpython.com/tags/461700
欢迎加入QQ群-->： 979659372
关于dagrun 相关联的Python项目和问题：
最新问答
我有一个关于更新python DAG文件的问题。
我有将近2000个DAG文件，我想在我的CI/CD管道上管理版本控制
我想要实现的是物理更新CI上的python文件，以便在将其发送到AIFLOW之前 ...
已阅读: n次
我在EC2上的24X大型机器上运行时遇到气流问题。在
我必须指出，并行级别是256。在
有几天，dagrun以“failed”状态结束，原因不明：
有些任务的状态为“上游失败”，这不是真的，因为我们 ...
已阅读: n次
我的DAG（我们称之为DAG_A）使用trigger_dagrun操作符启动另一个DAG（DAG_B）。DAG_B的任务使用XCOM，我希望在完成后从DAG_B的运行任务之一（正是我启动的任务）中获取 ...
已阅读: n次
我试图根据dagrun输入变量设置S3KeySensor的bucket_键。
我有一个dag“dag_触发器”，它使用TriggerDagRunOperator为dag“dag_trigged”触发d ...
已阅读: n次
在这种情况下，我试图从另一个DAG调用DAG（从父DAG调用目标DAG）
我的家长代码是：
from datetime import datetime
from airflow.models impo ...
已阅读: n次
为什么cli中的trigger_dag命令在重新启动后没有从失败的任务启动？你知道吗
我用Triggerdanrunoperator从外部触发dag。重新启动时，dagrun应该从失败的地方运行。你知 ...
已阅读: n次
我使用AirFlow来调度作业，但是它变得比以前慢了，特别是对于views.py中的task_stat方法，我有400多个dag，表task_instance中有300万行。
我要等40多秒才能得到t ...
已阅读: n次
我正在使用pytest测试需要任务上下文（因此需要DAG）的气流任务。
有两个文件：
conftest.py：包含pytext装置的文件
test_bash.py：包含任务测试的文件
这是DAG的 ...
已阅读: n次
我使用气流1.7.1.3。在
我对并发DAGs/Tasks有问题。当一个DAG正在运行时，调度程序不再启动其他DAG。调度程序似乎完全冻结了（不再有日志）。。。直到运行的DAG完成。然后，新的DAGr ...
已阅读: n次
我想查找特定执行日期特定dag的所有dag运行
正如我在文档中看到的，有以下功能：
dag_runs = DagRun.find(dag_id=self.dag_name, execution_dat ...
已阅读: n次
我很困惑如果达格伦失败了气流会怎么做。我想要达到的行为是：
DAG的常规触发器（每小时）
任务的重试次数
如果任务重试n次失败，请发送有关失败的电子邮件
当下一个每小时触发一次时，触发一个新的dag ...
已阅读: n次
我尝试从python代码中手动触发dag，如下所示：
from airflow_local.operators.mmttrigger_dagrun_operator import \
MMTTrigg ...
已阅读: n次
最新项目
