summary refs log tree commit diff
path: root/synapse/storage/data_stores/main/state.py
diff options
context:
space:
mode:
authorAndrew Morgan <andrew@amorgan.xyz>2020-03-16 15:31:27 +0000
committerAndrew Morgan <andrew@amorgan.xyz>2020-03-16 15:31:27 +0000
commit6d1e88a9425ad0d4caed5bf00f3eca5f0c45b114 (patch)
tree56007dbf6268899f2b2fdcd8089bc4e6862a1783 /synapse/storage/data_stores/main/state.py
parentMerge pull request #6253 from matrix-org/uhoreg/e2e_backup_delete_keys (diff)
parentConvert EventContext to attrs (#6218) (diff)
downloadsynapse-6d1e88a9425ad0d4caed5bf00f3eca5f0c45b114.tar.xz
Convert EventContext to attrs (#6218)
* commit '9aee28927':
  Convert EventContext to attrs (#6218)
Diffstat (limited to 'synapse/storage/data_stores/main/state.py')
-rw-r--r--synapse/storage/data_stores/main/state.py7
1 files changed, 6 insertions, 1 deletions
diff --git a/synapse/storage/data_stores/main/state.py b/synapse/storage/data_stores/main/state.py

index d54442e5fa..9b2207075b 100644 --- a/synapse/storage/data_stores/main/state.py +++ b/synapse/storage/data_stores/main/state.py
@@ -15,6 +15,7 @@ import logging from collections import namedtuple +from typing import Iterable, Tuple from six import iteritems, itervalues from six.moves import range @@ -23,6 +24,8 @@ from twisted.internet import defer from synapse.api.constants import EventTypes from synapse.api.errors import NotFoundError +from synapse.events import EventBase +from synapse.events.snapshot import EventContext from synapse.storage._base import SQLBaseStore from synapse.storage.background_updates import BackgroundUpdateStore from synapse.storage.data_stores.main.events_worker import EventsWorkerStore @@ -1215,7 +1218,9 @@ class StateStore(StateGroupWorkerStore, StateBackgroundUpdateStore): def __init__(self, db_conn, hs): super(StateStore, self).__init__(db_conn, hs) - def _store_event_state_mappings_txn(self, txn, events_and_contexts): + def _store_event_state_mappings_txn( + self, txn, events_and_contexts: Iterable[Tuple[EventBase, EventContext]] + ): state_groups = {} for event, context in events_and_contexts: if event.internal_metadata.is_outlier():