summary refs log tree commit diff
path: root/synapse/push/pusherpool.py
diff options
context:
space:
mode:
authorAndrew Morgan <andrew@amorgan.xyz>2021-04-21 15:35:38 +0100
committerAndrew Morgan <andrew@amorgan.xyz>2021-04-21 15:35:38 +0100
commit7ba1c6287574f3762537bbe7a9ab0d12d15a6c8c (patch)
treed0b0ffb2744e3fcace8312bfc4a2cee13b288a58 /synapse/push/pusherpool.py
parentMerge commit '1c9a85056' into anoa/dinsic_release_1_31_0 (diff)
parent1.25.0rc1 (diff)
downloadsynapse-7ba1c6287574f3762537bbe7a9ab0d12d15a6c8c.tar.xz
Merge commit '2fe0fb21f' into anoa/dinsic_release_1_31_0
Diffstat (limited to 'synapse/push/pusherpool.py')
-rw-r--r--synapse/push/pusherpool.py10
1 files changed, 5 insertions, 5 deletions
diff --git a/synapse/push/pusherpool.py b/synapse/push/pusherpool.py

index 37f3193917..3e843c97fe 100644 --- a/synapse/push/pusherpool.py +++ b/synapse/push/pusherpool.py
@@ -106,6 +106,10 @@ class PusherPool: time_now_msec = self.clock.time_msec() + # create the pusher setting last_stream_ordering to the current maximum + # stream ordering, so it will process pushes from this point onwards. + last_stream_ordering = self.store.get_room_max_stream_ordering() + # we try to create the pusher just to validate the config: it # will then get pulled out of the database, # recreated, added and started: this means we have only one @@ -124,16 +128,12 @@ class PusherPool: ts=time_now_msec, lang=lang, data=data, - last_stream_ordering=None, + last_stream_ordering=last_stream_ordering, last_success=None, failing_since=None, ) ) - # create the pusher setting last_stream_ordering to the current maximum - # stream ordering, so it will process pushes from this point onwards. - last_stream_ordering = self.store.get_room_max_stream_ordering() - await self.store.add_pusher( user_id=user_id, access_token=access_token,