summary refs log tree commit diff
path: root/synapse/notifier.py
diff options
context:
space:
mode:
authorOlivier Wilkinson (reivilibre) <olivier@librepush.net>2021-08-03 10:34:44 +0100
committerOlivier Wilkinson (reivilibre) <olivier@librepush.net>2021-08-03 10:34:44 +0100
commit11dda97e86579d807528392df7ba3c3efdd03c01 (patch)
tree003e6d55563e78ccca0e9f4a2b1c798231038370 /synapse/notifier.py
parentMerge branch 'release-v1.39' of github.com:matrix-org/synapse into matrix-org... (diff)
parentFix the `tests-done` github actions step, again (#10512) (diff)
downloadsynapse-11dda97e86579d807528392df7ba3c3efdd03c01.tar.xz
Merge remote-tracking branch 'origin/develop' into matrix-org-hotfixes
Diffstat (limited to 'synapse/notifier.py')
-rw-r--r--synapse/notifier.py5
1 files changed, 3 insertions, 2 deletions
diff --git a/synapse/notifier.py b/synapse/notifier.py

index c5fbebc17d..bbe337949a 100644 --- a/synapse/notifier.py +++ b/synapse/notifier.py
@@ -111,8 +111,9 @@ class _NotifierUserStream: self.last_notified_token = current_token self.last_notified_ms = time_now_ms - with PreserveLoggingContext(): - self.notify_deferred = ObservableDeferred(defer.Deferred()) + self.notify_deferred: ObservableDeferred[StreamToken] = ObservableDeferred( + defer.Deferred() + ) def notify( self,