diff --git a/internal/svc/consolidater.go b/internal/svc/consolidater.go
index f95a6bda..ea36fe91 100644
--- 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