From 665156fe88e5a475d3700fe0572ca04930711f21 Mon Sep 17 00:00:00 2001 From: David Robertson Date: Mon, 6 Feb 2023 13:54:40 +0000 Subject: Ignore false positives from run_as_background_process --- synapse/handlers/federation.py | 4 ++-- synapse/handlers/message.py | 2 +- synapse/metrics/background_process_metrics.py | 3 +++ synapse/metrics/common_usage_metrics.py | 2 +- 4 files changed, 7 insertions(+), 4 deletions(-) (limited to 'synapse') diff --git a/synapse/handlers/federation.py b/synapse/handlers/federation.py index 16057c030c..4e77bfa55e 100644 --- a/synapse/handlers/federation.py +++ b/synapse/handlers/federation.py @@ -192,7 +192,7 @@ class FederationHandler: # any partial-state-resync operations which were in flight when we # were shut down. if not hs.config.worker.worker_app: - run_as_background_process( + run_as_background_process( # type: ignore[unused-awaitable] "resume_sync_partial_state_room", self._resume_partial_state_room_sync ) @@ -1805,7 +1805,7 @@ class FederationHandler: room_id=room_id, ) - run_as_background_process( + run_as_background_process( # type: ignore[unused-awaitable] desc="sync_partial_state_room", func=_sync_partial_state_room_wrapper ) diff --git a/synapse/handlers/message.py b/synapse/handlers/message.py index 7dfebdc4aa..1c5fdca12a 100644 --- a/synapse/handlers/message.py +++ b/synapse/handlers/message.py @@ -1939,7 +1939,7 @@ class EventCreationHandler: if event.type == EventTypes.Message: # We don't want to block sending messages on any presence code. This # matters as sometimes presence code can take a while. - run_as_background_process( + run_as_background_process( # type: ignore[unused-awaitable] "bump_presence_active_time", self._bump_active_time, requester.user ) diff --git a/synapse/metrics/background_process_metrics.py b/synapse/metrics/background_process_metrics.py index 9ea4e23b31..ec6b95fdf3 100644 --- a/synapse/metrics/background_process_metrics.py +++ b/synapse/metrics/background_process_metrics.py @@ -207,6 +207,9 @@ def run_as_background_process( clock.looping_call and friends (or for firing-and-forgetting in the middle of a normal synapse async function). + Mypy will flag up this Deferred as unawaited. This is safe to ignore: the background + process runs automatically, even if we don't await the returned deferred. + Args: desc: a description for this background process type func: a function, which may return a Deferred or a coroutine diff --git a/synapse/metrics/common_usage_metrics.py b/synapse/metrics/common_usage_metrics.py index 6e05b043d3..bb7c3122b8 100644 --- a/synapse/metrics/common_usage_metrics.py +++ b/synapse/metrics/common_usage_metrics.py @@ -54,7 +54,7 @@ class CommonUsageMetricsManager: async def setup(self) -> None: """Keep the gauges for common usage metrics up to date.""" - run_as_background_process( + run_as_background_process( # type: ignore[unused-awaitable] desc="common_usage_metrics_update_gauges", func=self._update_gauges ) self._clock.looping_call( -- cgit 1.5.1