updated metrics

viant · Oct 8, 2024 · 2df4159 · 2df4159
1 parent 56b10f6
commit 2df4159
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/collector/service.go b/collector/service.go
@@ -344,6 +344,7 @@ func (s *Service) Flush(batch *Batch) error {
 		data := s.mapperFn(batch.Accumulator)
 		if err := s.load(context.Background(), data, batch.ID); err != nil {
 			atomic.StoreUint32(&batch.flushStarted, 0)
+			stats.Append(err)
 			return err
 		}