Revert "update"

This reverts commit a592e969fcf7c215e6991d6d4d22ffb7a3167fb2.

Author: NorthRealm

services/actions/clear_tasks.go

@@ -106,7 +106,7 @@ func CancelAbandonedJobs(ctx context.Context) error {
 		UpdatedBefore: timeutil.TimeStamp(time.Now().Add(-setting.Actions.AbandonedJobTimeout).Unix()),
 	})
 	if err != nil {
-		log.Error("CancelAbandonedJobs: %v", err)
+		log.Warn("find abandoned tasks: %v", err)
 		return err
 	}
 
@@ -124,7 +124,7 @@ func CancelAbandonedJobs(ctx context.Context) error {
 			updated = err == nil && n > 0
 			return err
 		}); err != nil {
-			log.Warn("CancelAbandonedJobs jobid %v: %v", job.ID, err)
+			log.Warn("cancel abandoned job %v: %v", job.ID, err)
 			// go on
 		}
 		CreateCommitStatus(ctx, job)
@@ -134,24 +134,18 @@ func CancelAbandonedJobs(ctx context.Context) error {
 		}
 	}
 
-	for _, obj := range updatedRuns {
-		jobs, err := actions_model.GetRunJobsByRunID(ctx, obj.RunID)
+	for _, job := range updatedRuns {
+		c, err := db.Count[actions_model.ActionRunJob](ctx, actions_model.FindRunJobOptions{
+			RunID:    job.RunID,
+			Statuses: []actions_model.Status{actions_model.StatusWaiting, actions_model.StatusBlocked, actions_model.StatusRunning},
+		})
 		if err != nil {
-			log.Error("CancelAbandonedJobs runid %d: %v", obj.RunID, err)
+			log.Error("Count waiting jobs for run %d: %v", job.RunID, err)
 			continue
 		}
-
-		unfinished := false
-		for _, job := range jobs {
-			if !job.Status.IsDone() {
-				unfinished = true
-				break
-			}
-		}
-		if unfinished {
-			continue
+		if c == 0 {
+			NotifyWorkflowRunStatusUpdateWithReload(ctx, job)
 		}
-		NotifyWorkflowRunStatusUpdateWithReload(ctx, obj)
 	}
 
 	return nil