WangHan
2024-09-12 d5855a4926926698b740bc6c7ba489de47adb68b
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
package tech.powerjob.server.core.workflow.hanlder;
 
import tech.powerjob.common.model.PEWorkflowDAG;
import tech.powerjob.server.persistence.remote.model.WorkflowInstanceInfoDO;
 
/**
 * @author Echo009
 * @since 2021/12/9
 */
public interface TaskNodeHandler extends WorkflowNodeHandlerMarker {
 
    /**
     * 创建任务实例
     *
     * @param node           目标节点
     * @param dag            DAG
     * @param wfInstanceInfo 工作流实例
     */
    void createTaskInstance(PEWorkflowDAG.Node node, PEWorkflowDAG dag, WorkflowInstanceInfoDO wfInstanceInfo);
 
    /**
     * 执行任务实例
     *
     * @param node 目标节点
     */
    void startTaskInstance(PEWorkflowDAG.Node node);
 
 
}