diff --git a/synapse/storage/events_worker.py b/synapse/storage/events_worker.py
index 5dc49822b5..e6b6b9d233 100644
--- a/synapse/storage/events_worker.py
+++ b/synapse/storage/events_worker.py
@@ -27,6 +27,7 @@ from synapse.api.constants import EventTypes
from synapse.api.errors import NotFoundError
from synapse.api.room_versions import EventFormatVersions
from synapse.events import FrozenEvent, event_type_from_format_version # noqa: F401
+
# these are only included to make the type annotations work
from synapse.events.snapshot import EventContext # noqa: F401
from synapse.events.utils import prune_event
@@ -111,8 +112,7 @@ class EventsWorkerStore(SQLBaseStore):
return ts
return self.runInteraction(
- "get_approximate_received_ts",
- _get_approximate_received_ts_txn,
+ "get_approximate_received_ts", _get_approximate_received_ts_txn
)
@defer.inlineCallbacks
@@ -298,9 +298,7 @@ class EventsWorkerStore(SQLBaseStore):
# that
expected_domain = get_domain_from_id(entry.event.sender)
- if (
- get_domain_from_id(orig_event_info["sender"]) == expected_domain
- ):
+ if get_domain_from_id(orig_event_info["sender"]) == expected_domain:
# This redaction event is allowed. Mark as not needing a
# recheck.
entry.event.internal_metadata.recheck_redaction = False
@@ -692,7 +690,8 @@ class EventsWorkerStore(SQLBaseStore):
"""
return self.runInteraction(
"get_total_state_event_counts",
- self._get_total_state_event_counts_txn, room_id
+ self._get_total_state_event_counts_txn,
+ room_id,
)
def _get_current_state_event_counts_txn(self, txn, room_id):
@@ -716,7 +715,8 @@ class EventsWorkerStore(SQLBaseStore):
"""
return self.runInteraction(
"get_current_state_event_counts",
- self._get_current_state_event_counts_txn, room_id
+ self._get_current_state_event_counts_txn,
+ room_id,
)
@defer.inlineCallbacks
|
