(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210848292.9 (22)申请日 2022.07.19 (71)申请人 上海致景信息科技有限公司 地址 200000 上海市虹口区东大名路1 158 号3201室 (72)发明人 陈钟浩　姚海杰　黄婷　殷萧鹏　 (74)专利代理 机构 广州立诚聚凡专利代理事务 所(普通合伙) 44905 专利代理师 郑义千 (51)Int.Cl. G06F 9/48(2006.01) G06F 9/50(2006.01) G06F 16/906(2019.01) (54)发明名称 支持异常时任务重跑的调度方法、 系统、 设 备及存储介质 (57)摘要 本发明涉及一种支持异常时任务重跑的调 度方法、 系统、 设备及存储介质， 其技术方案要 点 是： 根据预设配置规则对多个任务进行配置形成 工作流； 从工作流中调度满足预设执行条件的任 务形成待执行任务集合， 根据不满足预设执行条 件的任务形成未执行任务集合； 将待执行任务集 合中的各个任务分发给对应的任务执行终端执 行； 判断所有任务执行结果信息是否均为任务执 行成功， 若为否， 则将所有执行失败的任务均记 为失败任务， 将所有失败任务和未执行任务集合 中的任务合并形成工作流； 本申请具有在出现任 务的失败的情况下， 能对失败的任务和未执行任 务进行自动重跑， 大大降低了开发以及运维人员 在修复任务时需要人工操作的复杂度的效果。 权利要求书2页 说明书9页 附图3页 CN 115080214 A 2022.09.20 CN 115080214 A 1.一种支持异常时任务重跑的调度方法， 其特 征在于， 包括： S1、 根据预设配置规则对多个任务进行配置形成工作流， 其中， 所述工作流的多个任务 之间存在执 行依赖顺序； S2、 根据所述执行依赖顺序从工作流中调度满足预设执行条件的任务形成待执行任务 集合， 根据不满足预设执 行条件的任务形成未 执行任务集合； S3、 将所述待执行任务集合中的各个任务分发给对应的任务执行终端执行， 并接收所 有所述任务执行终端反馈的任务执行结果信息； 其中， 所述任务执行结果信息为任务执行 成功或任务执 行失败； S4、 判断所有任务执行结果信息是否均为任务执行成功， 若为否， 则将所有执行失败的 任务均记为失败任务， 并执行步骤S5； 若为是， 则将所有执行成功的任务均记为成功任务， 并执行步骤S6； S5、 将所有失败任务和所述未执行任务集合中的任务合并形成工作流， 并返回执行步 骤S2； S6、 判断所述未执行任务集合是否为空， 若为否， 则将所述未执行任务集合作为工作 流， 并返回执 行步骤S2； 若为是， 则完成调度。 2.根据权利要求1所述的支持异常时任务重跑的调度方法， 其特征在于， 所述任务包 括： 任务事 件； 所述预设配置规则， 包括： 根据所述任务事 件将所有任务进行分类得到多个分类集 合； 根据预设任务执行逻辑将各个所述分类集合中的任务进行排序得到有序集合， 所述有 序集合的所有任务之间存在执 行顺序； 根据预设任务依赖关系在多个有序集合的任务之间建立依赖关系形成工作流， 所述工 作流的多个任务之间存在执 行依赖顺序。 3.根据权利要求2所述的支持异常时任务重跑的调度方法， 其特征在于， 所述任务还包 括： 任务时间； 在所述根据预设任务执行逻辑将各个所述分类集合中的任务进行排序得到 有序集合之后， 还 包括： 将所述有序集 合中排序最前的任务对应的任务时间作为该有序集 合的执行时间。 4.根据权利要求3所述的支持异常时任务重跑的调度方法， 其特征在于， 所述所述工作 流的多个任务之间存在执行依赖顺序是指所述工作流的多个任务之间存在前置执行依赖 关系或后置执 行依赖关系。 5.根据权利要求4所述的支持异常时任务重跑的调度方法， 其特征在于， 判断所述工作 流中的任务是否满足预设执 行条件的方法， 包括： 判断所有 有序集合的执行时间是否均小于当前时间； 若是， 则判定所有有序集合中的任务均为不满足预设执行条件的任务， 并返回执行所 述判断所有 有序集合的时间是否均小于当前时间步骤； 若否， 则将所有执行时间不小于当前时间的有序集合均记为待启动集合， 将所有执行 时间小于当前时间的有序集合均 记为未启动集合， 将所有 未启动集合中的任务判定为不满 足预设执行条件的任务， 判断所有待启动集合中的任务是否有与其具有 前置执行依赖 关系 的上游任务， 若是， 则将所有待启动集合中有上游任务的任务判定为不满足预设执行条件 的任务， 将所有待启动集合中没有上游任务的任务判定为满足预设执行条件的任务， 并记权　利　要　求　书 1/2 页 2 CN 115080214 A 2为待执行任务， 若否， 则将所有待启动集合中的任务均判定为满足预设执行条件的任务， 并 记为待执 行任务。 6.根据权利要求1所述的支持异常时任务重跑的调度方法， 其特征在于， 所述将所有失 败任务和所述未执行任务集合中的任务合并形成工作流， 包括： 根据所述执行依赖顺序将 所有失败 任务和所述未 执行任务集合中的任务 合并形成工作流。 7.一种支持异常时任务重跑的调度系统， 其特 征在于， 包括： 任务配置模块， 用于根据 预设配置规则对多个任务进行配置形成工作流， 其中， 所述工 作流的多个任务之间存在执 行依赖顺序； 任务调度模块， 用于根据所述执行依赖顺序从工作流中调度满足预设执行条件的任务 形成待执 行任务集合， 根据不满足预设执 行条件的任务形成未 执行任务集合； 任务分发模块， 用于将所述待执行任务集合中的各个任务分发给对应的任务执行终端 执行， 并接收所有 所述任务执行终端反馈的任务执行结果信息； 其中， 所述任务执行结果信 息为任务执 行成功或任务执 行失败； 第一判断模块， 用于判断所有任务执行结果信 息是否均为任务执行成功， 若为否， 则将 所有执行失败的任务均 记为失败任务， 并启动任务合并模块； 若为是， 则将所有 执行成功的 任务均记为成功任务， 并启动第二判断模块； 任务合并模块， 用于将所有失败任务和所述未执行任务集合中的任务合并形成工作 流， 并返回启动任务调度模块； 第二判断模块， 用于判断所述未执行任务集合是否为空， 若为否， 则将所述未执行任务 集合作为工作流， 并启动任务调度模块； 若为是， 则完成调度。 8.根据权利要求7所述的支持异常时任务重跑的调度系统， 其特征在于， 所述任务包 括： 任务事 件； 所述任务配置模块包括： 任务分类单 元， 用于根据所述任务事 件将所有任务进行分类得到多个分类集 合； 任务排序 单元， 用于根据预设任务执行逻辑将各个所述分类集合中的任务进行排序建 立有序集 合， 所述有序集 合的所有任务之间存在执 行顺序； 关系建立单元， 用于根据预设任务依赖关系在多个有序集合的任务之间建立依赖关系 形成工作流， 所述工作流的多个任务之间存在执 行依赖顺序。 9.一种计算机设备,包括存储器和处理器， 所述存储器存储有计算机程序， 其特征在 于， 所述处 理器执行所述计算机程序时实现权利要求1至 6中任一项所述的方法的步骤。 10.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机程序 被处理器执行时实现权利要求1至 6中任一项所述的方法的步骤。权　利　要　求　书 2/2 页 3 CN 115080214 A 3