diff --git a/cmd/consolidate-duplicate-product-warehouses/main.go b/cmd/consolidate-duplicate-product-warehouses/main.go
index 91e7ced2..c3fe7f6f 100644
--- a/cmd/consolidate-duplicate-product-warehouses/main.go
+++ b/cmd/consolidate-duplicate-product-warehouses/main.go
@@ -228,8 +228,9 @@ func applyConsolidation(ctx context.Context, db *gorm.DB, groups []duplicateGrou
 
 			// Delete absorbed product_warehouses
 			res = tx.WithContext(ctx).
+				Table("product_warehouses").
 				Where("id IN ?", absorbedIDs).
-				Delete(&struct{}{})
+				Delete(nil)
 			if res.Error != nil {
 				return fmt.Errorf("delete absorbed: %w", res.Error)
 			}