diff options
| author | Amber Brown <hawkowl@atleastfornow.net> | 2019-04-03 20:07:29 +1100 |
|---|---|---|
| committer | Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | 2019-04-03 10:07:29 +0100 |
| commit | 7efd1d87c2c424365c99ba6103135edb1845fd88 (patch) | |
| tree | eadf93e88f277cca7f6fb694c8457ca5c73f5646 /synapse/storage/state_deltas.py | |
| parent | Merge pull request #4991 from matrix-org/erikj/stagger_push_startup (diff) | |
| download | synapse-7efd1d87c2c424365c99ba6103135edb1845fd88.tar.xz | |
Run black on the rest of the storage module (#4996)
Diffstat (limited to 'synapse/storage/state_deltas.py')
| -rw-r--r-- | synapse/storage/state_deltas.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/synapse/storage/state_deltas.py b/synapse/storage/state_deltas.py index 57bc45cdb9..56e42f583d 100644 --- a/synapse/storage/state_deltas.py +++ b/synapse/storage/state_deltas.py @@ -21,10 +21,11 @@ logger = logging.getLogger(__name__) class StateDeltasStore(SQLBaseStore): - def get_current_state_deltas(self, prev_stream_id): prev_stream_id = int(prev_stream_id) - if not self._curr_state_delta_stream_cache.has_any_entity_changed(prev_stream_id): + if not self._curr_state_delta_stream_cache.has_any_entity_changed( + prev_stream_id + ): return [] def get_current_state_deltas_txn(txn): @@ -58,7 +59,7 @@ class StateDeltasStore(SQLBaseStore): WHERE ? < stream_id AND stream_id <= ? ORDER BY stream_id ASC """ - txn.execute(sql, (prev_stream_id, max_stream_id,)) + txn.execute(sql, (prev_stream_id, max_stream_id)) return self.cursor_to_dict(txn) return self.runInteraction( |