remove debug

Author: func25

lib/logstorage/async_task_worker.go

@@ -78,7 +78,6 @@ func (s *Storage) executeTasksOnce(ctx context.Context) (uint64, error) {
 		return 0, nil
 	}
 
-	logger.Infof("DEBUG (task): found task seq=%d", task.Seq)
 	seq = task.Seq
 
 	// Gather all lagging parts in the target partition for this sequence.
@@ -127,7 +126,6 @@ func (s *Storage) executeTasksOnce(ctx context.Context) (uint64, error) {
 	}()
 
 	if task.Type == asyncTaskDelete {
-		logger.Infof("DEBUG (task): start deleting (seq=%d) on %d lagging parts (%d pending)", task.Seq, len(lagging), pending)
 		err := s.processDeleteTask(ctx, task, lagging)
 		if err != nil {
 			return 0, fmt.Errorf("run delete task: %w", err)
@@ -142,7 +140,6 @@ func (s *Storage) executeTasksOnce(ctx context.Context) (uint64, error) {
 		s.setTaskComplete(outdatedPtws, task.Seq, false, nil)
 	}
 
-	logger.Infof("DEBUG (task): task (seq=%d, query=%q) applied to %d parts", task.Seq, task.Payload.Query, len(lagging))
 	return seq, nil
 }
 
@@ -186,8 +183,6 @@ func (s *Storage) setTaskComplete(ptws []*partitionWrapper, taskSeq uint64, incl
 
 		pt.ats.resolve(taskSeq, err)
 	}
-
-	logger.Infof("DEBUG (task): resolveAsyncTask: taskSeq=%d, includeParts=%t, err=%v", taskSeq, includeParts, err)
 }
 
 func (s *Storage) processDeleteTask(ctx context.Context, task asyncTask, lagging []*partWrapper) error {

lib/logstorage/storage.go

@@ -832,7 +832,6 @@ func ValidateDeleteQuery(q *Query) error {
 		q.AddTimeFilter(minTS, now*1e9)
 	}
 
-	logger.Infof("DEBUG: query: %s, maxTS: %d, now: %d", q.String(), maxTS/1e9, now)
 	return nil
 }
 
@@ -982,6 +981,5 @@ func (s *Storage) markDeleteRowsOnParts(ctx context.Context, tenantIDs []TenantI
 	for i := range allowed {
 		partCount += len(allowed[i])
 	}
-	logger.Infof("DEBUG: affected (originalParts=%d, parts=%d, seq=%d)", partCount, len(partMarkers), seq)
 	return nil
 }