mirror of
https://github.com/matrix-org/dendrite.git
synced 2026-01-03 12:13:09 -06:00
Fix copy & paste mistake
This commit is contained in:
parent
ab06914a8e
commit
733dde497c
|
|
@ -226,7 +226,7 @@ func (s *queueEDUsStatements) DeleteExpiredEDUs(
|
||||||
ctx context.Context, txn *sql.Tx,
|
ctx context.Context, txn *sql.Tx,
|
||||||
expiredBefore gomatrixserverlib.Timestamp,
|
expiredBefore gomatrixserverlib.Timestamp,
|
||||||
) error {
|
) error {
|
||||||
stmt := sqlutil.TxStmt(txn, s.selectExpiredEDUsStmt)
|
stmt := sqlutil.TxStmt(txn, s.deleteExpiredEDUsStmt)
|
||||||
_, err := stmt.ExecContext(ctx, expiredBefore)
|
_, err := stmt.ExecContext(ctx, expiredBefore)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -238,7 +238,7 @@ func (s *queueEDUsStatements) DeleteExpiredEDUs(
|
||||||
ctx context.Context, txn *sql.Tx,
|
ctx context.Context, txn *sql.Tx,
|
||||||
expiredBefore gomatrixserverlib.Timestamp,
|
expiredBefore gomatrixserverlib.Timestamp,
|
||||||
) error {
|
) error {
|
||||||
stmt := sqlutil.TxStmt(txn, s.selectExpiredEDUsStmt)
|
stmt := sqlutil.TxStmt(txn, s.deleteExpiredEDUsStmt)
|
||||||
_, err := stmt.ExecContext(ctx, expiredBefore)
|
_, err := stmt.ExecContext(ctx, expiredBefore)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue