Fix lint.

ray-project · Jan 30, 2024 · acaef11 · acaef11
1 parent 55d7fe1
commit acaef11
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/fed/_private/message_queue.py b/fed/_private/message_queue.py
@@ -97,7 +97,9 @@ def stop(self, wait_for_sending=True):
             self._notify_to_exit(immediately=not wait_for_sending)
             if wait_for_sending:
                 self._thread.join()
-                logger.info(f"The message polling thread[{self._thread_name}] was exited.")
+                logger.info(
+                    f"The message polling thread[{self._thread_name}] was exited."
+                )
 
     def is_started(self):
         return self._thread is not None and self._thread.is_alive()