mirror of
https://github.com/PowerJob/PowerJob.git
synced 2025-07-17 00:00:04 +08:00
docs: 改动较大的类文件添加 @author 注释
This commit is contained in:
parent
783ea4f67f
commit
fa3981d167
@ -17,6 +17,7 @@ import java.util.Set;
|
||||
* DAG 工具类
|
||||
*
|
||||
* @author tjq
|
||||
* @author Echo009
|
||||
* @since 2020/5/26
|
||||
*/
|
||||
public class WorkflowDAGUtils {
|
||||
|
@ -33,6 +33,7 @@ import static com.github.kfcfans.powerjob.common.InstanceStatus.*;
|
||||
* 派送服务(将任务从Server派发到Worker)
|
||||
*
|
||||
* @author tjq
|
||||
* @author Echo009
|
||||
* @since 2020/4/5
|
||||
*/
|
||||
@Slf4j
|
||||
|
@ -35,6 +35,7 @@ import static com.github.kfcfans.powerjob.server.common.utils.WorkflowDAGUtils.i
|
||||
* 管理运行中的工作流实例
|
||||
*
|
||||
* @author tjq
|
||||
* @author Echo009
|
||||
* @since 2020/5/26
|
||||
*/
|
||||
@Slf4j
|
||||
@ -417,10 +418,10 @@ public class WorkflowInstanceManager {
|
||||
}
|
||||
|
||||
|
||||
private boolean isFinish(PEWorkflowDAG dag){
|
||||
private boolean isFinish(PEWorkflowDAG dag) {
|
||||
for (PEWorkflowDAG.Node node : dag.getNodes()) {
|
||||
if (InstanceStatus.GENERALIZED_RUNNING_STATUS.contains(node.getStatus())) {
|
||||
return false;
|
||||
return false;
|
||||
}
|
||||
}
|
||||
return true;
|
||||
|
@ -29,6 +29,7 @@ import static com.github.kfcfans.powerjob.server.common.utils.WorkflowDAGUtils.i
|
||||
* 工作流实例服务
|
||||
*
|
||||
* @author tjq
|
||||
* @author Echo009
|
||||
* @since 2020/5/31
|
||||
*/
|
||||
@Slf4j
|
||||
|
Loading…
x
Reference in New Issue
Block a user