fix: progressJobMaintenance was not cleaning properly job_progress table

Author: segator

server/repository/repository.go

@@ -682,7 +682,6 @@ func (s *SQLRepository) deleteProgressJob(ctx context.Context, conn SQLDBOperati
 		return err
 	}
 	return nil
-
 }
 
 func (s *SQLRepository) getAllProgressJobs(ctx context.Context, conn SQLDBOperations) ([]model.TaskProgressType, error) {
@@ -693,7 +692,7 @@ func (s *SQLRepository) getAllProgressJobs(ctx context.Context, conn SQLDBOperat
 	defer rows.Close()
 	var progressJobs []model.TaskProgressType
 	var etaSeconds float64
-	if rows.Next() {
+	for rows.Next() {
 		progress := model.TaskProgressType{}
 		err = rows.Scan(&progress.ProgressID, &progress.NotificationType, &progress.JobId, &progress.WorkerName, &progress.Percent, &etaSeconds, &progress.EventTime)
 		if err != nil {

server/scheduler/scheduler.go

@@ -240,7 +240,7 @@ func (r *RuntimeScheduler) scheduleRoutine(ctx context.Context) {
 		case checksumPath := <-r.checksumChan:
 			r.pathChecksumMap[checksumPath.path] = checksumPath.checksum
 		case <-progressTicker.C:
-			if err := r.progressJobMaitenance(ctx); err != nil {
+			if err := r.progressJobMaintenance(ctx); err != nil {
 				log.Errorf("Error on progress job maintenance: %s", err)
 			}
 		case <-maintenanceTicker.C:
@@ -499,7 +499,7 @@ func (r *RuntimeScheduler) stop() {
 
 }
 
-func (r *RuntimeScheduler) progressJobMaitenance(ctx context.Context) error {
+func (r *RuntimeScheduler) progressJobMaintenance(ctx context.Context) error {
 	progressJobs, err := r.repo.GetAllProgressJobs(ctx)
 	if err != nil {
 		return err