Browse Source

fix sagemaker sync status (#13264)

JieguangZhou 2 years ago
parent
commit
df491f78cc

+ 1 - 1
dolphinscheduler-task-plugin/dolphinscheduler-task-sagemaker/src/main/java/org/apache/dolphinscheduler/plugin/task/sagemaker/PipelineUtils.java

@@ -72,7 +72,7 @@ public class PipelineUtils {
             logger.info("check Pipeline Steps running");
             listPipelineExecutionSteps(client, pipelineId);
             ThreadUtils.sleep(SagemakerConstants.CHECK_PIPELINE_EXECUTION_STATUS_INTERVAL);
-            describePipelineExecution(client, pipelineId);
+            pipelineStatus = describePipelineExecution(client, pipelineId);
         }
 
         int exitStatusCode = TaskConstants.EXIT_CODE_FAILURE;