From df491f78cc0830b7fe19cb01581673d5c5dc9cf0 Mon Sep 17 00:00:00 2001 From: JieguangZhou Date: Thu, 22 Dec 2022 20:17:17 +0800 Subject: [PATCH] fix sagemaker sync status (#13264) --- .../dolphinscheduler/plugin/task/sagemaker/PipelineUtils.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dolphinscheduler-task-plugin/dolphinscheduler-task-sagemaker/src/main/java/org/apache/dolphinscheduler/plugin/task/sagemaker/PipelineUtils.java b/dolphinscheduler-task-plugin/dolphinscheduler-task-sagemaker/src/main/java/org/apache/dolphinscheduler/plugin/task/sagemaker/PipelineUtils.java index a70637e046..10722f3f29 100644 --- a/dolphinscheduler-task-plugin/dolphinscheduler-task-sagemaker/src/main/java/org/apache/dolphinscheduler/plugin/task/sagemaker/PipelineUtils.java +++ b/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;