shovel/task: log number of deleted updates during reorg

indexsupply · Apr 30, 2024 · 1c96080 · 1c96080
1 parent 8d3af08
commit 1c96080
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/shovel/task.go b/shovel/task.go
@@ -238,14 +238,18 @@ func (t *Task) Delete(pg wpg.Conn, n uint64) error {
 		and ig_name = $2
 		and num >= $3
 	`
-	_, err := pg.Exec(t.ctx, q, t.srcName, t.destConfig.Name, n)
+	cmd, err := pg.Exec(t.ctx, q, t.srcName, t.destConfig.Name, n)
 	if err != nil {
 		return fmt.Errorf("deleting block from task table: %w", err)
 	}
 	err = t.dests[0].Delete(t.ctx, pg, n)
 	if err != nil {
 		return fmt.Errorf("deleting block: %w", err)
 	}
+	slog.InfoContext(t.ctx, "task-delete",
+		"n", n,
+		"task_updates", cmd.RowsAffected(),
+	)
 	return nil
 }