From 8cf510714fa3b099402d8bb6e327dfb06dd0586c Mon Sep 17 00:00:00 2001
From: Artem Poltorzhitskiy <aopoltorzhicky@gmail.com>
Date: Tue, 18 Jun 2024 15:23:07 +0200
Subject: [PATCH] Fix: stuck R2 (#220)

---
 internal/blob/r2.go | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/internal/blob/r2.go b/internal/blob/r2.go
index 3418fb37..127aaee1 100644
--- 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)
+		}()
 	}
 }