From c12a3b0f0af57e7b069a55cab0cb26e9455de5b9 Mon Sep 17 00:00:00 2001
From: Gilbertsoft <25326036+gilbertsoft@users.noreply.github.com>
Date: Fri, 23 Jun 2023 20:29:37 +0200
Subject: [PATCH] fix: avoid lost of events on transmission failure (#56)

---
 amplitude/plugins/destination/amplitude_plugin.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/amplitude/plugins/destination/amplitude_plugin.go b/amplitude/plugins/destination/amplitude_plugin.go
index 8705770..56cb5e9 100644
--- a/amplitude/plugins/destination/amplitude_plugin.go
+++ b/amplitude/plugins/destination/amplitude_plugin.go
@@ -192,6 +192,10 @@ func (p *amplitudePlugin) sendEventsFromStorage(wg *sync.WaitGroup) {
 			p.reduceChunkSize()
 		}
 
+		if len(result.EventsForRetry) > 0 {
+			p.storage.ReturnBack(result.EventsForRetry...)
+		}
+
 		executeCallback := p.config.ExecuteCallback
 		if executeCallback != nil && len(result.EventsForCallback) > 0 {
 			go func() {