Skip to content

Commit 291adfb

Browse files
authored
[Chore-17377][Master] Rename methods in StateAction for better readability. (#17379)
1 parent f81709c commit 291adfb

43 files changed

Lines changed: 591 additions & 591 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/lifecycle/handler/TaskDispatchLifecycleEventHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ public void handle(final ITaskStateAction taskStateAction,
3737
final IWorkflowExecutionRunnable workflowExecutionRunnable,
3838
final ITaskExecutionRunnable taskExecutionRunnable,
3939
final TaskDispatchLifecycleEvent event) {
40-
taskStateAction.dispatchEventAction(workflowExecutionRunnable, taskExecutionRunnable, event);
40+
taskStateAction.onDispatchEvent(workflowExecutionRunnable, taskExecutionRunnable, event);
4141
}
4242

4343
@Override

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/lifecycle/handler/TaskDispatchedLifecycleEventHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ public void handle(final ITaskStateAction taskStateAction,
4848
final IWorkflowExecutionRunnable workflowExecutionRunnable,
4949
final ITaskExecutionRunnable taskExecutionRunnable,
5050
final TaskDispatchedLifecycleEvent taskDispatchedEvent) {
51-
taskStateAction.dispatchedEventAction(workflowExecutionRunnable, taskExecutionRunnable, taskDispatchedEvent);
51+
taskStateAction.onDispatchedEvent(workflowExecutionRunnable, taskExecutionRunnable, taskDispatchedEvent);
5252
taskExecutorClient.ackTaskExecutorLifecycleEvent(
5353
taskExecutionRunnable,
5454
new ITaskExecutorLifecycleEventReporter.TaskExecutorLifecycleEventAck(

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/lifecycle/handler/TaskFailedLifecycleEventHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ public void handle(final ITaskStateAction taskStateAction,
4343
final IWorkflowExecutionRunnable workflowExecutionRunnable,
4444
final ITaskExecutionRunnable taskExecutionRunnable,
4545
final TaskFailedLifecycleEvent event) {
46-
taskStateAction.failedEventAction(workflowExecutionRunnable, taskExecutionRunnable, event);
46+
taskStateAction.onFailedEvent(workflowExecutionRunnable, taskExecutionRunnable, event);
4747
taskExecutorClient.ackTaskExecutorLifecycleEvent(
4848
taskExecutionRunnable,
4949
new ITaskExecutorLifecycleEventReporter.TaskExecutorLifecycleEventAck(

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/lifecycle/handler/TaskFailoverLifecycleEventHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ public void handle(final ITaskStateAction taskStateAction,
3434
final IWorkflowExecutionRunnable workflowExecutionRunnable,
3535
final ITaskExecutionRunnable taskExecutionRunnable,
3636
final TaskFailoverLifecycleEvent taskFailoverEvent) {
37-
taskStateAction.failoverEventAction(workflowExecutionRunnable, taskExecutionRunnable, taskFailoverEvent);
37+
taskStateAction.onFailoverEvent(workflowExecutionRunnable, taskExecutionRunnable, taskFailoverEvent);
3838
}
3939

4040
@Override

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/lifecycle/handler/TaskKillLifecycleEventHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ public void handle(final ITaskStateAction taskStateAction,
3737
final IWorkflowExecutionRunnable workflowExecutionRunnable,
3838
final ITaskExecutionRunnable taskExecutionRunnable,
3939
final TaskKillLifecycleEvent taskKillEvent) {
40-
taskStateAction.killEventAction(workflowExecutionRunnable, taskExecutionRunnable, taskKillEvent);
40+
taskStateAction.onKillEvent(workflowExecutionRunnable, taskExecutionRunnable, taskKillEvent);
4141
}
4242

4343
@Override

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/lifecycle/handler/TaskKilledLifecycleEventHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ public void handle(final ITaskStateAction taskStateAction,
4343
final IWorkflowExecutionRunnable workflowExecutionRunnable,
4444
final ITaskExecutionRunnable taskExecutionRunnable,
4545
final TaskKilledLifecycleEvent taskKilledEvent) {
46-
taskStateAction.killedEventAction(workflowExecutionRunnable, taskExecutionRunnable, taskKilledEvent);
46+
taskStateAction.onKilledEvent(workflowExecutionRunnable, taskExecutionRunnable, taskKilledEvent);
4747
taskExecutorClient.ackTaskExecutorLifecycleEvent(
4848
taskExecutionRunnable,
4949
new ITaskExecutorLifecycleEventReporter.TaskExecutorLifecycleEventAck(

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/lifecycle/handler/TaskPauseLifecycleEventHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ public void handle(final ITaskStateAction taskStateAction,
3434
final IWorkflowExecutionRunnable workflowExecutionRunnable,
3535
final ITaskExecutionRunnable taskExecutionRunnable,
3636
final TaskPauseLifecycleEvent taskPauseEvent) {
37-
taskStateAction.pauseEventAction(workflowExecutionRunnable, taskExecutionRunnable, taskPauseEvent);
37+
taskStateAction.onPauseEvent(workflowExecutionRunnable, taskExecutionRunnable, taskPauseEvent);
3838
}
3939

4040
@Override

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/lifecycle/handler/TaskPausedLifecycleEventHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ public void handle(final ITaskStateAction taskStateAction,
4343
final IWorkflowExecutionRunnable workflowExecutionRunnable,
4444
final ITaskExecutionRunnable taskExecutionRunnable,
4545
final TaskPausedLifecycleEvent event) {
46-
taskStateAction.pausedEventAction(workflowExecutionRunnable, taskExecutionRunnable, event);
46+
taskStateAction.onPausedEvent(workflowExecutionRunnable, taskExecutionRunnable, event);
4747
taskExecutorClient.ackTaskExecutorLifecycleEvent(
4848
taskExecutionRunnable,
4949
new ITaskExecutorLifecycleEventReporter.TaskExecutorLifecycleEventAck(

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/lifecycle/handler/TaskRetryLifecycleEventHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ public void handle(final ITaskStateAction taskStateAction,
3737
final IWorkflowExecutionRunnable workflowExecutionRunnable,
3838
final ITaskExecutionRunnable taskExecutionRunnable,
3939
final TaskRetryLifecycleEvent taskRetryLifecycleEvent) {
40-
taskStateAction.retryEventAction(workflowExecutionRunnable, taskExecutionRunnable, taskRetryLifecycleEvent);
40+
taskStateAction.onRetryEvent(workflowExecutionRunnable, taskExecutionRunnable, taskRetryLifecycleEvent);
4141
}
4242

4343
@Override

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/engine/task/lifecycle/handler/TaskRunningLifecycleEventHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ public void handle(final ITaskStateAction taskStateAction,
4646
final IWorkflowExecutionRunnable workflowExecutionRunnable,
4747
final ITaskExecutionRunnable taskExecutionRunnable,
4848
final TaskRunningLifecycleEvent taskRunningEvent) {
49-
taskStateAction.startedEventAction(workflowExecutionRunnable, taskExecutionRunnable, taskRunningEvent);
49+
taskStateAction.onStartedEvent(workflowExecutionRunnable, taskExecutionRunnable, taskRunningEvent);
5050
taskExecutorClient.ackTaskExecutorLifecycleEvent(
5151
taskExecutionRunnable,
5252
new ITaskExecutorLifecycleEventReporter.TaskExecutorLifecycleEventAck(

0 commit comments

Comments
 (0)