diff --git a/federationapi/storage/postgres/queue_edus_table.go b/federationapi/storage/postgres/queue_edus_table.go
index a7ca328ef..787a35cbb 100644
--- a/federationapi/storage/postgres/queue_edus_table.go
+++ b/federationapi/storage/postgres/queue_edus_table.go
@@ -226,7 +226,7 @@ func (s *queueEDUsStatements) DeleteExpiredEDUs(
 	ctx context.Context, txn *sql.Tx,
 	expiredBefore gomatrixserverlib.Timestamp,
 ) error {
-	stmt := sqlutil.TxStmt(txn, s.selectExpiredEDUsStmt)
+	stmt := sqlutil.TxStmt(txn, s.deleteExpiredEDUsStmt)
 	_, err := stmt.ExecContext(ctx, expiredBefore)
 	return err
 }
diff --git a/federationapi/storage/sqlite3/queue_edus_table.go b/federationapi/storage/sqlite3/queue_edus_table.go
index a2a60b29c..013f73923 100644
--- a/federationapi/storage/sqlite3/queue_edus_table.go
+++ b/federationapi/storage/sqlite3/queue_edus_table.go
@@ -238,7 +238,7 @@ func (s *queueEDUsStatements) DeleteExpiredEDUs(
 	ctx context.Context, txn *sql.Tx,
 	expiredBefore gomatrixserverlib.Timestamp,
 ) error {
-	stmt := sqlutil.TxStmt(txn, s.selectExpiredEDUsStmt)
+	stmt := sqlutil.TxStmt(txn, s.deleteExpiredEDUsStmt)
 	_, err := stmt.ExecContext(ctx, expiredBefore)
 	return err
 }