summary refs log tree commit diff
path: root/synapse/push/bulk_push_rule_evaluator.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2019-12-05 10:43:49 +0000
committerGitHub <noreply@github.com>2019-12-05 10:43:49 +0000
commitddbbfc9512cd9b66d3af57ab5e9fb1e5a0418913 (patch)
treeeb061c5e86be7baf9428161715637a0f12bb2ff3 /synapse/push/bulk_push_rule_evaluator.py
parentMerge pull request #6470 from matrix-org/babolivier/port_db_ci_failure (diff)
parentNewsfile (diff)
downloadsynapse-ddbbfc9512cd9b66d3af57ab5e9fb1e5a0418913.tar.xz
Merge pull request #6464 from matrix-org/erikj/make_public_sql_base
Clean up SQLBaseStore private function usage
Diffstat (limited to 'synapse/push/bulk_push_rule_evaluator.py')
-rw-r--r--synapse/push/bulk_push_rule_evaluator.py10
1 files changed, 1 insertions, 9 deletions
diff --git a/synapse/push/bulk_push_rule_evaluator.py b/synapse/push/bulk_push_rule_evaluator.py

index 1ba7bcd4d8..7881780760 100644 --- a/synapse/push/bulk_push_rule_evaluator.py +++ b/synapse/push/bulk_push_rule_evaluator.py
@@ -386,15 +386,7 @@ class RulesForRoom(object): """ sequence = self.sequence - rows = yield self.store._simple_select_many_batch( - table="room_memberships", - column="event_id", - iterable=member_event_ids.values(), - retcols=("user_id", "membership", "event_id"), - keyvalues={}, - batch_size=500, - desc="_get_rules_for_member_event_ids", - ) + rows = yield self.store.get_membership_from_event_ids(member_event_ids.values()) members = {row["event_id"]: (row["user_id"], row["membership"]) for row in rows}