Airflow 重跑dag中部分失败的任务

重跑dag中部分失败的任务

例如 dagA 中, T1 >> T2 >> T3 >> T4 >> T5  ,其中 T1 T2 成功, T3 失败, T4  T5因为依赖 T3,也不会运行。

跳过 T1   T2  重跑 T3 T4 T5 的方法是:

(1)点击 T3 clear ,默认会clear T4  T5 的状态

(2)返回到上一级,点击 dagA 名字,点击 Recursive 和 Downstream (airflow的界面,看不出来到底有没有选择,反正各点一次,  Uncheck ),然后点击 clear

原文地址:https://www.cnblogs.com/zjc10203/p/9671059.html

时间: 2024-07-30 03:40:48

Airflow 重跑dag中部分失败的任务的相关文章

RF失败案例重跑

1.1        失败案例重跑 该功能主要是针对上次连跑失败的案例需要重新执行测试的情况,可自动识别上次执行失败的案例并进行重跑,无需手动选择相应的案例,简单高效. 1.5.1.        重跑项目失败案例 命令格式:"pybot -R 上次执行失败的output.xml文件所在路径 -d 本次重跑结果output.xml文件保存路径 项目所在路径", 其中的参数包括"上次执行失败的output.xml文件所在路径"."本次重跑结果output.x

python3 unittest框架失败重跑加截图支持python2,python3

github源码地址下载:https://github.com/GoverSky/HTMLTestRunner_cn.git 解压文件后取出/HTMLTestRunner_cn.py文件丢进C:\Python37\Lib\site-packages目录下 如何使用报告截图重跑机制:how to use it ? 代码编写注意事项:该模板暂时不支持setup初始化驱动driver,而且初始化驱动必须取名driver,关于 HTMLTestRunner 新增参数 retry=1表示失败后重跑的次数,

solr与.net系列课程(八)solr中重跑索引的注意事项

solr与.net系列课程(八)solr中重跑索引的注意事项 我们如果在项目中使用solr,那肯定就是把数据库中的数据跑进solr服务器中,solr有两种操作一种是新建索引,一种是增量索引,这里我们来说一说新建索引的一下注意事项 终止跑索引                  http://192.168.0.9:8080/solr/collection1/dataimport?command=abort 开始索引                     http://192.168.0.9:80

pytest_html报告报错截图+失败重跑

前言 做web自动化的小伙伴应该都希望在html报告中展示失败后的截图,提升报告的档次,pytest-html也可以生成带截图的报告. conftest.py 1.失败截图可以写到conftest.py文件里,这样用例运行时,只要检测到用例实例,就调用截图的方法,并且把截图存到html报告上 # conftest.py文件 # coding:utf-8 from selenium import webdriver import pytest driver = None @pytest.mark.

hive--新增字段,数据重跑坑

场景: 当我们建表完成并按照时间分区插入数据,之后我们发现需要增加一个字段. 办法: 我们首先想到的是先在表中增加字段. 1)alter table table_name add columns(new_attr string); 然后重跑数据 2)insert overwrite table table_name partition(pattr='20181029') 这种后果是,我们新增的字段new_attr的值为空. 解决办法: 在insert之前,一定记得删该分区 1.5)alter t

Swift中可能失败的构造器的传播(调用)和重写

import Foundation /* 可能失败构造器的传播(调用) 1.可能失败的构造器可以调用同一个类中的普通构造器 2.普通构造器不能调用同一个类中的可能失败构造器 3.结构体中, 普通构造器却可以调用同一个结构体中可能失败的构造器 可能失败构造器的重写 1.子类可以用可能失败的构造器或者普通的构造器重写父类中的可能失败的构造器 2.子类的普通构造器不能向上调用父类的可能失败的构造器 3.子类的可能失败的构造器可以调用父类的可能失败的构造器 */ class Person { var n

流量来源分析 0801 0810 0820 流量数据重跑

重跑这3天的数据执行过程和遇到的问题: ①执行 sh siteKeyDataNew.sh 3 20140801 ; 错误提示: awk: cmd. line:39: fatal: cannot open file `../data_today/row_data_20140801*' for reading (No such file or directory)awk: cmd. line:35: fatal: cannot open file `../data_today/row_data_20

(转)解决jdk1.8中发送邮件失败(handshake_failure)问题

解决jdk1.8中发送邮件失败(handshake_failure)问题 作者 zhisheng_tian 2016.08.12 22:44* 字数 1573 阅读 2818评论 6喜欢 9 暑假在家做一个类似知乎的问答型网站(代码可见:Github/wenda 喜欢的可以给个star或者自己fork然后修改,目前功能还未很完善),其中有一个站内邮件通知系统(这里简单的讲一个例子:如果用户登录的时候出现异常,那么就会通过邮件发送通知用户).然而却碰到一个问题.问题错误信息如下: 发送邮件失败Ma

LA 3126 二分匹配---DAG中的最小路径应用

题意:有 n 个顾客 , 需要坐出租车从一个地方去另一个地方 , 每个顾客的出发时间.出发地点.目的地点都已给出 , 从出发地点到目的地点的时间为两地之间的路径长度 , 并且出租车要比顾客的出发时间早一分钟到达 , 问最少需要派出多少辆出租车. 解法:我们先这样来构图 , 每个顾客是一个结点,如果同一个出租车在接完客人 u 之后还来得及节客人 v , 那么就在 u 到 v 之间连一条有向边 . 由此可以发现 , 这个图是一个DAG , 那么我们就只需要找最小路径覆盖(最小路径覆盖:是指在图中找尽