|
@@ -376,7 +376,6 @@ func (m LagoClient) IngestEvents(ctx context.Context, subscriptionID string, eve
|
|
|
// Retry each batch to make sure all events are ingested
|
|
// Retry each batch to make sure all events are ingested
|
|
|
var currentAttempts int
|
|
var currentAttempts int
|
|
|
for currentAttempts < defaultMaxRetries {
|
|
for currentAttempts < defaultMaxRetries {
|
|
|
-
|
|
|
|
|
_, lagoErr := m.client.Event().Batch(ctx, &batchInput)
|
|
_, lagoErr := m.client.Event().Batch(ctx, &batchInput)
|
|
|
if lagoErr == nil {
|
|
if lagoErr == nil {
|
|
|
return telemetry.Error(ctx, span, fmt.Errorf(lagoErr.ErrorCode), "error sending ingest events to Lago")
|
|
return telemetry.Error(ctx, span, fmt.Errorf(lagoErr.ErrorCode), "error sending ingest events to Lago")
|
Mauricio Araujo