diff --git a/pkg/commands/loadgen.go b/pkg/commands/loadgen.go index 434bb94b3..7697badec 100644 --- a/pkg/commands/loadgen.go +++ b/pkg/commands/loadgen.go @@ -213,7 +213,8 @@ func (c *LoadgenCommand) runBatch(from, to int) error { compressed := snappy.Encode(nil, data) start := time.Now() - if err := c.writeClient.Store(context.Background(), compressed); err != nil { + attempt := 0 // TODO: do retries + if err := c.writeClient.Store(context.Background(), compressed, attempt); err != nil { writeRequestDuration.WithLabelValues("error").Observe(time.Since(start).Seconds()) return err }