diff --git a/batch/sql/dedup_billing_project_users.py b/batch/sql/dedup_billing_project_users.py index 04fbf671c7e..5533e63e5e7 100644 --- a/batch/sql/dedup_billing_project_users.py +++ b/batch/sql/dedup_billing_project_users.py @@ -120,7 +120,7 @@ async def audit_changes(db): bad_bp_user_records = db.select_and_fetchall( f''' -SELECT old.billing_project, old.`user`, old.resource_id, old.`usage`, new.`usage`, ABS(new.`usage` - old.`usage`) AS usage_diff +SELECT old.billing_project, old.`user`, old.deduped_resource_id, old.`usage`, new.`usage`, ABS(new.`usage` - old.`usage`) AS usage_diff FROM ( SELECT billing_project, `user`, deduped_resource_id, CAST(COALESCE(SUM(`usage`), 0) AS SIGNED) AS `usage` FROM aggregated_billing_project_user_resources_v2