From 733dde497ca6083a1adeb265f25926909b322cf2 Mon Sep 17 00:00:00 2001 From: Till Faelligen Date: Fri, 29 Apr 2022 19:33:24 +0200 Subject: [PATCH] Fix copy & paste mistake --- federationapi/storage/postgres/queue_edus_table.go | 2 +- federationapi/storage/sqlite3/queue_edus_table.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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 }