Change FileWatcher to stop printing watchfiles debug log

The underlying Rust code performs periodic checks to see
if it should stop watching. These checks raise TimeoutError,
which by default would log misleading debug messages.
Setting yield_on_timeout=True makes it yield an empty
set instead of printing debug logs.
We handle these empty sets in the `ready()` method by
continuing to wait.

src/frequenz/channels/file_watcher.py

@@ -159,6 +159,11 @@ def __init__(
             watch_filter=self._filter_events,
             force_polling=force_polling,
             poll_delay_ms=int(polling_interval.total_seconds() * 1_000),
+            # The underlying Rust code performs periodic checks to see if it should stop watching.
+            # These checks raise TimeoutError, which by default would log misleading debug messages.
+            # Setting yield_on_timeout=True makes it yield an empty set instead of printing debug
+            # logs. We handle these empty sets in the `ready()` method by continuing to wait.
+            yield_on_timeout=True,
         )
         self._awatch_stopped_exc: Exception | None = None
         self._changes: set[FileChange] = set()
@@ -204,11 +209,16 @@ async def ready(self) -> bool:
         if self._awatch_stopped_exc is not None:
             return False
 
-        try:
-            self._changes = await anext(self._awatch)
-        except StopAsyncIteration as err:
-            self._awatch_stopped_exc = err
-            return False
+        # awatch will yield an empty set if rust notify timeout is reached.
+        # This is safety heartbeat mechanism for Windows.
+        # But on non-Windows systems, we don't need it, so we can ignore it.
+        # For more details, refer awatch documentation.
+        while len(self._changes) == 0:
+            try:
+                self._changes = await anext(self._awatch)
+            except StopAsyncIteration as err:
+                self._awatch_stopped_exc = err
+                return False
 
         return True
 

tests/test_file_watcher.py

@@ -102,6 +102,7 @@ async def test_file_watcher_filter_events(
                 watch_filter=filter_events,
                 force_polling=True,
                 poll_delay_ms=1_000,
+                yield_on_timeout=True,
             )
         ]
         for event_type in EventType: