summary refs log tree commit diff
path: root/synapse/streams
diff options
context:
space:
mode:
Diffstat (limited to 'synapse/streams')
-rw-r--r--synapse/streams/config.py7
-rw-r--r--synapse/streams/events.py1
2 files changed, 3 insertions, 5 deletions
diff --git a/synapse/streams/config.py b/synapse/streams/config.py
index b6ffbab1e7..69c7145a36 100644
--- a/synapse/streams/config.py
+++ b/synapse/streams/config.py
@@ -27,7 +27,9 @@ class PaginationConfig(object):
     """A configuration object which stores pagination parameters."""
 
     def __init__(self, from_tok=None, to_tok=None, direction='f', limit=0):
-        self.from_token = StreamToken.from_string(from_tok) if from_tok else None
+        self.from_token = (
+            StreamToken.from_string(from_tok) if from_tok else None
+        )
         self.to_token = StreamToken.from_string(to_tok) if to_tok else None
         self.direction = 'f' if direction == 'f' else 'b'
         self.limit = int(limit)
@@ -67,6 +69,3 @@ class PaginationConfig(object):
             "<PaginationConfig from_tok=%s, to_tok=%s, "
             "direction=%s, limit=%s>"
         ) % (self.from_tok, self.to_tok, self.direction, self.limit)
-
-
-
diff --git a/synapse/streams/events.py b/synapse/streams/events.py
index 36174a811b..bf48df5b79 100644
--- a/synapse/streams/events.py
+++ b/synapse/streams/events.py
@@ -171,4 +171,3 @@ class StreamSource(object):
 class PaginationSource(object):
     def get_pagination_rows(self, user, from_token, to_token, limit, key):
         raise NotImplementedError("get_rows")
-