diff options
| author | Richard van der Hoff <richard@matrix.org> | 2018-10-24 09:24:55 +0100 |
|---|---|---|
| committer | Richard van der Hoff <richard@matrix.org> | 2018-10-24 09:24:55 +0100 |
| commit | c573794b22a47a0f03c80f2732922c3375e7b74c (patch) | |
| tree | dcd3a1498e65235dd7aa7517eb7a2a7fbe4eabbe | |
| parent | sanity-check the is_processing flag (diff) | |
| download | synapse-c573794b22a47a0f03c80f2732922c3375e7b74c.tar.xz | |
Fix start_pushers vs _start_pushers confusion
| -rw-r--r-- | synapse/push/pusherpool.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/synapse/push/pusherpool.py b/synapse/push/pusherpool.py index d25877cc66..5a4e73ccd6 100644 --- a/synapse/push/pusherpool.py +++ b/synapse/push/pusherpool.py @@ -41,7 +41,7 @@ class PusherPool: def __init__(self, _hs): self.hs = _hs self.pusher_factory = PusherFactory(_hs) - self.start_pushers = _hs.config.start_pushers + self._should_start_pushers = _hs.config.start_pushers self.store = self.hs.get_datastore() self.clock = self.hs.get_clock() self.pushers = {} @@ -49,7 +49,7 @@ class PusherPool: def start(self): """Starts the pushers off in a background process. """ - if not self.start_pushers: + if not self._should_start_pushers: logger.info("Not starting pushers because they are disabled in the config") return run_as_background_process("start_pushers", self._start_pushers) @@ -175,7 +175,7 @@ class PusherPool: @defer.inlineCallbacks def start_pusher_by_id(self, app_id, pushkey, user_id): """Look up the details for the given pusher, and start it""" - if not self._start_pushers: + if not self._should_start_pushers: return resultlist = yield self.store.get_pushers_by_app_id_and_pushkey( |