You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ca...@apache.org on 2023/07/14 10:40:08 UTC
[dolphinscheduler] branch dev updated (c812bf9d49 -> e6d94632b9)
This is an automated email from the ASF dual-hosted git repository.
caishunfeng pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
from c812bf9d49 [Bug] [Mater] Not got latest task intance by task code (#14529)
add e6d94632b9 Add WorkflowExecuteContext (#14544)
No new revisions were added by this update.
Summary of changes:
.../dolphinscheduler/api/dto/gantt/GanttDto.java | 48 +-
.../service/impl/ProcessDefinitionServiceImpl.java | 22 +-
.../service/impl/ProcessInstanceServiceImpl.java | 12 +-
.../api/service/ProcessInstanceServiceTest.java | 6 +-
.../common/model/TaskNodeRelation.java | 60 +--
.../master/event/WorkflowStartEventHandler.java | 11 +-
.../master/event/WorkflowStateEventHandler.java | 3 +-
.../event/WorkflowTimeoutStateEventHandler.java | 3 +-
.../IWorkflowGraph.java} | 15 +-
.../server/master/graph/WorkflowGraph.java | 69 +++
.../server/master/graph/WorkflowGraphFactory.java | 132 +++++
.../server/master/runner/EventExecuteService.java | 3 +-
.../master/runner/IWorkflowExecuteContext.java | 20 +-
...itStatus.java => IWorkflowExecuteRunnable.java} | 26 +-
.../master/runner/MasterSchedulerBootstrap.java | 3 +-
.../master/runner/StateWheelExecuteThread.java | 6 +-
.../master/runner/WorkflowExecuteContext.java | 43 +-
...ory.java => WorkflowExecuteContextFactory.java} | 69 +--
.../master/runner/WorkflowExecuteRunnable.java | 555 +++++++++------------
.../runner/WorkflowExecuteRunnableFactory.java | 49 +-
.../master/runner/WorkflowExecuteThreadPool.java | 31 +-
...wSubmitStatus.java => WorkflowStartStatus.java} | 2 +-
.../execute/DefaultTaskExecuteRunnableFactory.java | 2 +-
.../runner/task/blocking/BlockingLogicTask.java | 3 +-
.../runner/task/switchtask/SwitchLogicTask.java | 6 +-
.../server/master/service/ExecutingService.java | 3 +-
.../master/service/WorkerFailoverService.java | 3 +-
.../ProcessInstanceExecCacheManagerImplTest.java | 8 +-
.../master/runner/WorkflowExecuteRunnableTest.java | 58 ++-
.../server/master/service/FailoverServiceTest.java | 6 +-
.../dolphinscheduler/service/model/TaskNode.java | 8 +-
.../service/process/ProcessService.java | 2 +-
.../service/process/ProcessServiceImpl.java | 2 +-
.../dolphinscheduler/service/utils/DagHelper.java | 170 ++++---
.../service/process/ProcessServiceTest.java | 2 +-
.../service/utils/DagHelperTest.java | 184 +++----
.../plugin/task/api/model/SwitchResultVo.java | 12 +-
.../task/api/parameters/ConditionsParameters.java | 39 +-
.../task/api/parameters/SwitchParameters.java | 14 +-
39 files changed, 855 insertions(+), 855 deletions(-)
copy dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/{runner/execute/AsyncTaskCallbackFunction.java => graph/IWorkflowGraph.java} (64%)
create mode 100644 dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/graph/WorkflowGraph.java
create mode 100644 dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/graph/WorkflowGraphFactory.java
copy dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/executor/workflow/instance/stop/StopResult.java => dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/IWorkflowExecuteContext.java (67%)
copy dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/{WorkflowSubmitStatus.java => IWorkflowExecuteRunnable.java} (71%)
copy dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/executor/ExecuteContext.java => dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteContext.java (51%)
copy dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/{WorkflowExecuteRunnableFactory.java => WorkflowExecuteContextFactory.java} (60%)
rename dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/{WorkflowSubmitStatus.java => WorkflowStartStatus.java} (96%)