|
|
@ -86,11 +86,11 @@ public class MlflowTask extends AbstractTaskExecutor { |
|
|
|
// construct process
|
|
|
|
// construct process
|
|
|
|
String command = buildCommand(); |
|
|
|
String command = buildCommand(); |
|
|
|
TaskResponse commandExecuteResult = shellCommandExecutor.run(command); |
|
|
|
TaskResponse commandExecuteResult = shellCommandExecutor.run(command); |
|
|
|
int exitCode = exitStatusCode; |
|
|
|
int exitCode; |
|
|
|
if (mlflowParameters.getIsDeployDocker()){ |
|
|
|
if (mlflowParameters.getIsDeployDocker()){ |
|
|
|
exitCode = checkDockerHealth(); |
|
|
|
exitCode = checkDockerHealth(); |
|
|
|
}else { |
|
|
|
}else { |
|
|
|
exitCode = getExitStatusCode(); |
|
|
|
exitCode = commandExecuteResult.getExitStatusCode(); |
|
|
|
} |
|
|
|
} |
|
|
|
setExitStatusCode(exitCode); |
|
|
|
setExitStatusCode(exitCode); |
|
|
|
setAppIds(commandExecuteResult.getAppIds()); |
|
|
|
setAppIds(commandExecuteResult.getAppIds()); |
|
|
|