diff --git a/synapse/storage/databases/main/schema/delta/58/11recovery_after_outage.sql b/synapse/storage/databases/main/schema/delta/58/11recovery_after_outage.sql
index c903419eb4..5e331cc7c6 100644
--- a/synapse/storage/databases/main/schema/delta/58/11recovery_after_outage.sql
+++ b/synapse/storage/databases/main/schema/delta/58/11recovery_after_outage.sql
@@ -16,7 +16,7 @@
 -- after there has been a connectivity problem for any reason.
 
 -- This stores, for each (destination, room) pair, the event_id and stream_ordering
--- of the latest event to be enqueued for transmission to that destination.
+-- of the latest event for that destination.
 CREATE TABLE IF NOT EXISTS destination_rooms (
   -- the destination in question
   destination TEXT NOT NULL,
diff --git a/synapse/storage/databases/main/transactions.py b/synapse/storage/databases/main/transactions.py
index 6c6f51cdd0..052dffcd1b 100644
--- a/synapse/storage/databases/main/transactions.py
+++ b/synapse/storage/databases/main/transactions.py
@@ -159,7 +159,7 @@ class TransactionStore(SQLBaseStore):
             allow_none=True,
         )
 
-        if result and result["retry_last_ts"] and result["retry_last_ts"] > 0:
+        if result and result["retry_last_ts"]:
             return result
         else:
             return None