diff --git a/synapse/storage/stats.py b/synapse/storage/stats.py
index b65eef72bd..b1df526b54 100644
--- a/synapse/storage/stats.py
+++ b/synapse/storage/stats.py
@@ -808,7 +808,8 @@ class StatsStore(StateDeltasStore):
                 txn,
                 table + "_current",
                 {id_col: stats_id},
-                retcols=selected_columns + ["start_ts", "end_ts"],
+                retcols=selected_columns
+                + ["start_ts", "end_ts", "completed_delta_stream_id"],
                 allow_none=True,
             )