1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/storage/transactions.py b/synapse/storage/transactions.py
index b5ed5453d8..92eec69ef4 100644
--- a/synapse/storage/transactions.py
+++ b/synapse/storage/transactions.py
@@ -122,7 +122,7 @@ class TransactionStore(SQLBaseStore):
             )
 
         txn.execute(query, (destination,))
-        results = SentTransactions.decode_results(txn)
+        results = SentTransactions.decode_results(txn.fetchall())
 
         prev_txns = [r.transaction_id for r in results]