pylint

Author: Andrei Neagu

services/dynamic-sidecar/src/simcore_service_dynamic_sidecar/modules/attribute_monitor/_logging_event_handler.py

@@ -76,12 +76,12 @@ def _stop_process(self) -> None:
             logging.DEBUG,
             f"{_LoggingEventHandlerProcess.__name__} stop_process",
         ):
-            self._stop_queue.put(None)
+            self._stop_queue.put(None)  # pylint:disable=no-member
 
             if self._process:
                 # force stop the process
-                self._process.kill()
-                self._process.join()
+                self._process.kill()  # pylint:disable=no-member
+                self._process.join()  # pylint:disable=no-member
                 self._process = None
 
             # cleanup whatever remains
@@ -109,7 +109,7 @@ def _process_worker(self) -> None:
             )
             observer.start()
 
-            while self._stop_queue.qsize() == 0:
+            while self._stop_queue.qsize() == 0:  # pylint:disable=no-member
                 # NOTE: watchdog handles events internally every 1 second.
                 # While doing so it will block this thread briefly.
                 # Health check delivery may be delayed.
@@ -171,7 +171,7 @@ async def _health_worker(self) -> None:
             heart_beat_count = 0
             while True:
                 try:
-                    self._health_check_queue.get_nowait()
+                    self._health_check_queue.get_nowait()  # pylint:disable=no-member
                     heart_beat_count += 1
                 except Empty:
                     break

services/dynamic-sidecar/src/simcore_service_dynamic_sidecar/modules/outputs/_event_handler.py

@@ -103,12 +103,12 @@ def stop_process(self) -> None:
         with log_context(
             _logger, logging.DEBUG, f"{_EventHandlerProcess.__name__} stop_process"
         ):
-            self._stop_queue.put(None)
+            self._stop_queue.put(None)  # pylint:disable=no-member
 
             if self._process:
                 # force stop the process
-                self._process.kill()
-                self._process.join()
+                self._process.kill()  # pylint:disable=no-member
+                self._process.join()  # pylint:disable=no-member
                 self._process = None
 
             # cleanup whatever remains
@@ -123,8 +123,10 @@ def shutdown(self) -> None:
             self.stop_process()
 
             # signal queue observers to finish
-            self.outputs_context.port_key_events_queue.put(None)
-            self.health_check_queue.put(None)
+            self.outputs_context.port_key_events_queue.put(
+                None
+            )  # pylint:disable=no-member
+            self.health_check_queue.put(None)  # pylint:disable=no-member
 
     def _thread_worker_update_outputs_port_keys(self) -> None:
         # NOTE: runs as a thread in the created process
@@ -133,7 +135,9 @@ def _thread_worker_update_outputs_port_keys(self) -> None:
         while True:
             message: dict[
                 str, Any
-            ] | None = self.outputs_context.file_system_event_handler_queue.get()
+            ] | None = (
+                self.outputs_context.file_system_event_handler_queue.get()  # pylint:disable=no-member
+            )
             _logger.debug("received message %s", message)
 
             # no more messages quitting
@@ -173,7 +177,7 @@ def _process_worker(self) -> None:
             )
             observer.start()
 
-            while self._stop_queue.qsize() == 0:
+            while self._stop_queue.qsize() == 0:  # pylint:disable=no-member
                 # watchdog internally uses 1 sec interval to detect events
                 # sleeping for less is useless.
                 # If this value is bigger then the DEFAULT_OBSERVER_TIMEOUT
@@ -183,7 +187,9 @@ def _process_worker(self) -> None:
                 # time while handling inotify events
                 # the health_check sending could be delayed
 
-                self.health_check_queue.put(_HEART_BEAT_MARK)
+                self.health_check_queue.put(  # pylint:disable=no-member
+                    _HEART_BEAT_MARK
+                )
                 blocking_sleep(self.heart_beat_interval_s)
 
         except Exception:  # pylint: disable=broad-except
@@ -196,7 +202,9 @@ def _process_worker(self) -> None:
             observer.stop()
 
             # stop created thread
-            self.outputs_context.file_system_event_handler_queue.put(None)
+            self.outputs_context.file_system_event_handler_queue.put(  # pylint:disable=no-member
+                None
+            )
             thread_update_outputs_port_keys.join()
 
             _logger.warning("%s exited", _EventHandlerProcess.__name__)
@@ -246,7 +254,7 @@ async def _health_worker(self) -> None:
             heart_beat_count = 0
             while True:
                 try:
-                    self._health_check_queue.get_nowait()
+                    self._health_check_queue.get_nowait()  # pylint:disable=no-member
                     heart_beat_count += 1
                 except Empty:
                     break