fix: avoid lost of events on transmission failure (#56)

amplitude · Jun 23, 2023 · c12a3b0 · c12a3b0
1 parent 1e75f7b
commit c12a3b0
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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() {