diff --git a/synapse/storage/databases/main/events_worker.py b/synapse/storage/databases/main/events_worker.py
index b385c15ba9a5..761b15a8150a 100644
--- a/synapse/storage/databases/main/events_worker.py
+++ b/synapse/storage/databases/main/events_worker.py
@@ -396,7 +396,7 @@ def process_replication_rows(
             for row in rows:
                 assert isinstance(row, UnPartialStatedEventStreamRow)
 
-                self.is_partial_state_event.invalidate(row.event_id)
+                self.is_partial_state_event.invalidate((row.event_id,))
 
                 if row.rejection_status_changed:
                     # If the partial-stated event became rejected or unrejected