diff --git a/storagenode/piecestore/endpoint.go b/storagenode/piecestore/endpoint.go
index f803830df4b4..63fe8cf58754 100644
--- a/storagenode/piecestore/endpoint.go
+++ b/storagenode/piecestore/endpoint.go
@@ -979,7 +979,7 @@ func (endpoint *Endpoint) Retain(ctx context.Context, retainReq *pb.RetainReques
 	if queued {
 		endpoint.log.Info("Retain job queued", zap.Stringer("Satellite ID", peer.ID))
 	} else {
-		endpoint.log.Info("Retain job not queued (job already exists)", zap.Stringer("Satellite ID", peer.ID))
+		endpoint.log.Info("Retain job not queued (queue is closed)", zap.Stringer("Satellite ID", peer.ID))
 	}
 
 	return &pb.RetainResponse{}, nil
diff --git a/storagenode/retain/retain.go b/storagenode/retain/retain.go
index a9bc2519b1ad..4c8a70d8bb74 100644
--- a/storagenode/retain/retain.go
+++ b/storagenode/retain/retain.go
@@ -118,8 +118,7 @@ func NewService(log *zap.Logger, store *pieces.Store, config Config) *Service {
 }
 
 // Queue adds a retain request to the queue.
-// It discards a request for a satellite that already has a queued request.
-// true is returned if the request is queued and false is returned if it is discarded.
+// true is returned if the request is added to the queue, false if queue is closed.
 func (s *Service) Queue(req Request) bool {
 	s.cond.L.Lock()
 	defer s.cond.L.Unlock()