diff --git a/consumer/src/db/record.rs b/consumer/src/db/record.rs
index 9e5e55e1..208e46de 100644
--- a/consumer/src/db/record.rs
+++ b/consumer/src/db/record.rs
@@ -562,7 +562,7 @@ pub async fn repost_delete<C: GenericClient>(
 ) -> PgOptResult<String> {
     let res = conn
         .query_opt(
-            "DELETE FROM reposts WHERE rkey=$1 AND repo=$2 RETURNING post",
+            "DELETE FROM reposts WHERE rkey=$1 AND did=$2 RETURNING post",
             &[&rkey, &repo],
         )
         .await?;