diff options
| author | Erik Johnston <erik@matrix.org> | 2018-06-01 11:53:06 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2018-06-01 11:53:43 +0100 |
| commit | e7bb34b72a36b7a4889618c2d00e1f8b3d826a50 (patch) | |
| tree | 4624bf474bc5d5ace792fae20eba5e3b715adc96 | |
| parent | Reuse stream_ordering attribute instead of order (diff) | |
| download | synapse-e7bb34b72a36b7a4889618c2d00e1f8b3d826a50.tar.xz | |
Use *row
| -rw-r--r-- | synapse/storage/stream.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/storage/stream.py b/synapse/storage/stream.py index d46672aa4a..b3492d9109 100644 --- a/synapse/storage/stream.py +++ b/synapse/storage/stream.py @@ -774,7 +774,7 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore): txn.execute(sql, args) - rows = [_EventDictReturn(row[0], row[1], row[2], row[3]) for row in txn] + rows = [_EventDictReturn(*row) for row in txn] # If we are paginating topologically and we haven't hit the limit on # number of events then we need to fetch events from the previous or @@ -824,7 +824,7 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore): break txn.execute(sql, args) - new_rows = [_EventDictReturn(row[0], row[1], row[2], row[3]) for row in txn] + new_rows = [_EventDictReturn(*row) for row in txn] if not new_rows: break |