diff --git a/internal/service/upload_service.go b/internal/service/upload_service.go index bf6ea25..6c482ac 100644 --- a/internal/service/upload_service.go +++ b/internal/service/upload_service.go @@ -357,8 +357,9 @@ func (s *UploadService) CompleteUpload(ctx context.Context, sessionID int64) (*m keys[i] = fmt.Sprintf("%schunk_%05d", minioPrefix, i) } go func() { - bgCtx := context.Background() - if delErr := s.storage.RemoveObjects(bgCtx, s.cfg.Bucket, keys, storage.RemoveObjectsOptions{}); delErr != nil { + ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) + defer cancel() + if delErr := s.storage.RemoveObjects(ctx, s.cfg.Bucket, keys, storage.RemoveObjectsOptions{}); delErr != nil { s.logger.Warn("delete temp chunks", zap.Error(delErr)) } }()