simplify while loop when listening for synchronizer messages

canvas-medical · Jan 29, 2025 · 0856151 · 0856151
1 parent da3992a
commit 0856151
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/plugin_runner/plugin_runner.py b/plugin_runner/plugin_runner.py
@@ -213,11 +213,10 @@ async def synchronize_plugins(max_iterations: None | int = None) -> None:
     await pubsub.psubscribe(CHANNEL_NAME)
     log.info("Listening for messages on pubsub channel")
     iterations: int = 0
-    while True:
-        if max_iterations is not None:  # max_iterations == -1 means infinite iterations
-            if iterations >= max_iterations:
-                break
-            iterations += 1
+    while (
+        max_iterations is None or iterations < max_iterations
+    ):  # max_iterations == -1 means infinite iterations
+        iterations += 1
         message = await pubsub.get_message(ignore_subscribe_messages=True)
         if message is not None:
             log.info("Received message from pubsub channel")