Fix: stuck R2 (#220)

celenium-io · Jun 18, 2024 · 8cf5107 · 8cf5107
1 parent df3710b
commit 8cf5107
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/internal/blob/r2.go b/internal/blob/r2.go
@@ -182,7 +182,9 @@ func (r2 *R2) saveBlob(ctx context.Context, blob Blob) {
 	log.Info().Str("blob", blob.String()).Int("size", blob.Size()).Msg("saving blob...")
 	if err := r2.Save(timeoutCtx, blob); err != nil {
 		log.Err(err).Str("blob", blob.String()).Int("size", blob.Size()).Msg("blob saving")
-		// if error occurred try again
-		r2.pool.AddTask(blob)
+		go func() {
+			// if error occurred try again
+			r2.pool.AddTask(blob)
+		}()
 	}
 }