You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by zh...@apache.org on 2022/07/12 12:58:59 UTC

[dolphinscheduler] branch dev updated: [fix] mlflow project success status (#10897)

This is an automated email from the ASF dual-hosted git repository.

zhongjiajie pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 02b2de2a1e [fix] mlflow project success status (#10897)
02b2de2a1e is described below

commit 02b2de2a1e3198b96eb5b6a4c42411ec265e1731
Author: JieguangZhou <ji...@163.com>
AuthorDate: Tue Jul 12 20:58:53 2022 +0800

    [fix] mlflow project success status (#10897)
    
    close: #10902
---
 .../org/apache/dolphinscheduler/plugin/task/mlflow/MlflowTask.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-mlflow/src/main/java/org/apache/dolphinscheduler/plugin/task/mlflow/MlflowTask.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-mlflow/src/main/java/org/apache/dolphinscheduler/plugin/task/mlflow/MlflowTask.java
index 88da235ff0..6c87162354 100644
--- a/dolphinscheduler-task-plugin/dolphinscheduler-task-mlflow/src/main/java/org/apache/dolphinscheduler/plugin/task/mlflow/MlflowTask.java
+++ b/dolphinscheduler-task-plugin/dolphinscheduler-task-mlflow/src/main/java/org/apache/dolphinscheduler/plugin/task/mlflow/MlflowTask.java
@@ -86,11 +86,11 @@ public class MlflowTask extends AbstractTaskExecutor {
             // construct process
             String command = buildCommand();
             TaskResponse commandExecuteResult = shellCommandExecutor.run(command);
-            int exitCode = exitStatusCode;
+            int exitCode;
             if (mlflowParameters.getIsDeployDocker()){
                 exitCode = checkDockerHealth();
             }else {
-                exitCode = getExitStatusCode();
+                exitCode = commandExecuteResult.getExitStatusCode();
             }
             setExitStatusCode(exitCode);
             setAppIds(commandExecuteResult.getAppIds());