diff options
author | David Robertson <davidr@element.io> | 2023-09-08 19:29:38 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-09-08 19:29:38 +0100 |
commit | edd83f23b710f0caae05d5766b474de3b6f24e9e (patch) | |
tree | 91c841f77e186fea9ede52df87d50126541162d1 /synapse/storage | |
parent | Upgrade CI run of Python 3.12 from rc1 to rc2 (#16280) (diff) | |
download | synapse-edd83f23b710f0caae05d5766b474de3b6f24e9e.tar.xz |
Improve type hints for attrs classes (#16276)
Diffstat (limited to 'synapse/storage')
-rw-r--r-- | synapse/storage/controllers/persist_events.py | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/synapse/storage/controllers/persist_events.py b/synapse/storage/controllers/persist_events.py index abd1d149db..6864f93090 100644 --- a/synapse/storage/controllers/persist_events.py +++ b/synapse/storage/controllers/persist_events.py @@ -154,12 +154,13 @@ class _UpdateCurrentStateTask: _EventPersistQueueTask = Union[_PersistEventsTask, _UpdateCurrentStateTask] +_PersistResult = TypeVar("_PersistResult") @attr.s(auto_attribs=True, slots=True) -class _EventPersistQueueItem: +class _EventPersistQueueItem(Generic[_PersistResult]): task: _EventPersistQueueTask - deferred: ObservableDeferred + deferred: ObservableDeferred[_PersistResult] parent_opentracing_span_contexts: List = attr.ib(factory=list) """A list of opentracing spans waiting for this batch""" @@ -168,9 +169,6 @@ class _EventPersistQueueItem: """The opentracing span under which the persistence actually happened""" -_PersistResult = TypeVar("_PersistResult") - - class _EventPeristenceQueue(Generic[_PersistResult]): """Queues up tasks so that they can be processed with only one concurrent transaction per room. |