diff options
| author | Erik Johnston <erik@matrix.org> | 2019-05-16 10:18:53 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2019-05-16 10:38:13 +0100 |
| commit | b5c62c6b2643a138956af0b04521540c270a3e94 (patch) | |
| tree | 67752ed0fce75f373eb58553c0b2039c2f7d0fbe /synapse/storage/relations.py | |
| parent | Add cache to relations (diff) | |
| download | synapse-b5c62c6b2643a138956af0b04521540c270a3e94.tar.xz | |
Fix relations in worker mode
Diffstat (limited to 'synapse/storage/relations.py')
| -rw-r--r-- | synapse/storage/relations.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/synapse/storage/relations.py b/synapse/storage/relations.py index 1fd3d4fafc..732418ec65 100644 --- a/synapse/storage/relations.py +++ b/synapse/storage/relations.py @@ -109,7 +109,7 @@ class AggregationPaginationToken(object): return "%d-%d" % (self.count, self.stream) -class RelationsStore(SQLBaseStore): +class RelationsWorkerStore(SQLBaseStore): @cached(tree=True) def get_relations_for_event( self, @@ -318,6 +318,8 @@ class RelationsStore(SQLBaseStore): "get_aggregation_groups_for_event", _get_aggregation_groups_for_event_txn ) + +class RelationsStore(RelationsWorkerStore): def _handle_event_relations(self, txn, event): """Handles inserting relation data during peristence of events |