diff --git a/sda/cmd/finalize/finalize.go b/sda/cmd/finalize/finalize.go index 7a7011ae1..3a2bd33cd 100644 --- a/sda/cmd/finalize/finalize.go +++ b/sda/cmd/finalize/finalize.go @@ -110,6 +110,11 @@ func main() { case "enabled": case "ready": log.Infof("File with correlation ID %s is already marked as ready.", delivered.CorrelationId) + if err := delivered.Ack(false); err != nil { + log.Errorf("Failed acking message, reason: %v", err) + } + + continue default: log.Warnf("file with correlation ID: %s is not verified yet, stopping work", delivered.CorrelationId) if err := delivered.Nack(false, true); err != nil {