diff --git a/synapse/storage/event_push_actions.py b/synapse/storage/event_push_actions.py
index 6a122b05a8..214ace27c9 100644
--- a/synapse/storage/event_push_actions.py
+++ b/synapse/storage/event_push_actions.py
@@ -140,11 +140,13 @@ class EventPushActionsStore(SQLBaseStore):
                     (event.room_id, uid,)
                 )
 
+        # Now we delete the staging area for *all* events that were being
+        # persisted.
         txn.executemany(
             "DELETE FROM event_push_actions_staging WHERE event_id = ?",
             (
                 (event.event_id,)
-                for event, _ in events_and_contexts
+                for event, _ in all_events_and_contexts
             )
         )