Fix progress no push bug

WeDataSphere · Sep 4, 2023 · 59b85cf · 59b85cf
1 parent f385cd8
commit 59b85cf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../org/apache/linkis/engineconn/computation/executor/service/TaskExecutionServiceImpl.scala b/.../org/apache/linkis/engineconn/computation/executor/service/TaskExecutionServiceImpl.scala
@@ -427,7 +427,7 @@ class TaskExecutionServiceImpl
       override def run(): Unit = {
         Utils.tryQuietly(Thread.sleep(TimeUnit.MILLISECONDS.convert(1, TimeUnit.SECONDS)))
         while (null != taskFuture && !taskFuture.isDone) {
-          if (ExecutionNodeStatus.isCompleted(task.getStatus)) {
+          if (!ExecutionNodeStatus.isCompleted(task.getStatus)) {
             Utils.tryAndWarn {
               val progressResponse = Utils.tryAndWarn(taskProgress(task.getTaskId))
               val resourceResponse = Utils.tryAndWarn(buildResourceMap(task))