diff --git a/synapse/storage/stream.py b/synapse/storage/stream.py
index aa3c9f8c9..3c8f3320f 100644
--- a/synapse/storage/stream.py
+++ b/synapse/storage/stream.py
@@ -139,8 +139,8 @@ class StreamStore(SQLBaseStore):
             limit = MAX_STREAM_SIZE
 
         # From and to keys should be integers from ordering.
-        from_id = _StreamToken.parse_stream_token(from_key)
-        to_id = _StreamToken.parse_stream_token(to_key)
+        # from_id = _StreamToken.parse_stream_token(from_key)
+        # to_id = _StreamToken.parse_stream_token(to_key)
 
         if from_key == to_key:
             return defer.succeed(([], to_key))