Skip to content

Commit 3de2674

Browse files
Zzih96ruanwenjun
authored andcommitted
add getWorkflowExecutionRunnable Override
1 parent 0b705ad commit 3de2674

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/workflow/lifecycle/event/WorkflowTimeoutLifecycleEvent.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,9 +27,6 @@
2727

2828
import java.util.concurrent.TimeUnit;
2929

30-
import lombok.Getter;
31-
32-
@Getter
3330
public class WorkflowTimeoutLifecycleEvent extends AbstractWorkflowLifecycleLifecycleEvent {
3431

3532
private final IWorkflowExecutionRunnable workflowExecutionRunnable;
@@ -40,6 +37,11 @@ protected WorkflowTimeoutLifecycleEvent(final IWorkflowExecutionRunnable workflo
4037
this.workflowExecutionRunnable = workflowExecutionRunnable;
4138
}
4239

40+
@Override
41+
public IWorkflowExecutionRunnable getWorkflowExecutionRunnable() {
42+
return workflowExecutionRunnable;
43+
}
44+
4345
public static WorkflowTimeoutLifecycleEvent of(final IWorkflowExecutionRunnable workflowExecutionRunnable) {
4446
final WorkflowInstance workflowInstance = workflowExecutionRunnable.getWorkflowInstance();
4547
checkState(workflowInstance != null, "The workflow instance must be initialized before timeout monitoring.");

0 commit comments

Comments
 (0)