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%)