summary refs log tree commit diff
path: root/synapse/replication/tcp/streams/_base.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2020-03-24 16:00:54 +0000
committerErik Johnston <erik@matrix.org>2020-03-24 16:00:54 +0000
commite4c5b1d9d6be6a38224d274e8f38099d0ab550ac (patch)
treee1f059a3808afdc95e6b6a14ed6b6057ffb931e2 /synapse/replication/tcp/streams/_base.py
parentRemove import loop (diff)
downloadsynapse-e4c5b1d9d6be6a38224d274e8f38099d0ab550ac.tar.xz
Review comments
Diffstat (limited to '')
-rw-r--r--synapse/replication/tcp/streams/_base.py3
1 files changed, 0 insertions, 3 deletions
diff --git a/synapse/replication/tcp/streams/_base.py b/synapse/replication/tcp/streams/_base.py
index d5b9c2831b..d7e9371a00 100644
--- a/synapse/replication/tcp/streams/_base.py
+++ b/synapse/replication/tcp/streams/_base.py
@@ -105,9 +105,6 @@ class Stream(object):
             to fetch.
         """
 
-        if from_token in ("NOW", "now"):
-            return [], upto_token, False
-
         from_token = int(from_token)
 
         if from_token == upto_token: