fix: consolidation with collapsing does not release all the datasets

airbusgeo · Jan 25, 2024 · cc24497 · cc24497
1 parent a4ed1c8
commit cc24497
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/svc/consolidater.go b/internal/svc/consolidater.go
@@ -650,6 +650,8 @@ func (svc *Service) csldSwapDatasets(ctx context.Context, job *geocube.Job) erro
 			if err := txn.ChangeDatasetsStatus(ctx, job.ID, geocube.DatasetStatusACTIVE, geocube.DatasetStatusTODELETE); err != nil {
 				return err
 			}
+		} else {
+			job.ReleaseDatasets(geocube.LockFlagTODELETE)
 		}
 
 		// Inactive datasets are tagged active