diff options
| author | Amber Brown <hawkowl@atleastfornow.net> | 2019-06-20 19:32:02 +1000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-06-20 19:32:02 +1000 |
| commit | 32e7c9e7f20b57dd081023ac42d6931a8da9b3a3 (patch) | |
| tree | 139ef30c957535699d1ae0474e8b5ba2517196b2 /synapse/replication/slave/storage/presence.py | |
| parent | Merge pull request #5042 from matrix-org/erikj/fix_get_missing_events_error (diff) | |
| download | synapse-32e7c9e7f20b57dd081023ac42d6931a8da9b3a3.tar.xz | |
Run Black. (#5482)
Diffstat (limited to 'synapse/replication/slave/storage/presence.py')
| -rw-r--r-- | synapse/replication/slave/storage/presence.py | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/synapse/replication/slave/storage/presence.py b/synapse/replication/slave/storage/presence.py index 0ec1db25ce..82d808af4c 100644 --- a/synapse/replication/slave/storage/presence.py +++ b/synapse/replication/slave/storage/presence.py @@ -24,9 +24,7 @@ from ._slaved_id_tracker import SlavedIdTracker class SlavedPresenceStore(BaseSlavedStore): def __init__(self, db_conn, hs): super(SlavedPresenceStore, self).__init__(db_conn, hs) - self._presence_id_gen = SlavedIdTracker( - db_conn, "presence_stream", "stream_id", - ) + self._presence_id_gen = SlavedIdTracker(db_conn, "presence_stream", "stream_id") self._presence_on_startup = self._get_active_presence(db_conn) @@ -55,9 +53,7 @@ class SlavedPresenceStore(BaseSlavedStore): if stream_name == "presence": self._presence_id_gen.advance(token) for row in rows: - self.presence_stream_cache.entity_has_changed( - row.user_id, token - ) + self.presence_stream_cache.entity_has_changed(row.user_id, token) self._get_presence_for_user.invalidate((row.user_id,)) return super(SlavedPresenceStore, self).process_replication_rows( stream_name, token, rows |