Move log

artie-labs · Mar 29, 2024 · d16c4c7 · d16c4c7
1 parent c2651fc
commit d16c4c7
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/lib/writer/writer.go b/lib/writer/writer.go
@@ -37,12 +37,12 @@ func (w *Writer) Write(ctx context.Context, iter RawMessageIterator) (int, error
 				return 0, fmt.Errorf("failed to write messages: %w", err)
 			}
 			count += len(msgs)
+			slog.Info("Write progress",
+				slog.Duration("timing", time.Since(start)),
+				slog.Int("batchSize", len(msgs)),
+				slog.Int("total", count),
+			)
 		}
-		slog.Info("Write progress",
-			slog.Duration("timing", time.Since(start)),
-			slog.Int("batchSize", len(msgs)),
-			slog.Int("total", count),
-		)
 	}
 	return count, nil
 }