Merge pull request #5864 from clebergnu/drop_runner_queue

Signed-off-by: Jan Richter <[email protected]>

avocado/core/test.py

@@ -252,7 +252,6 @@ def __init__(
         params=None,
         base_logdir=None,
         config=None,
-        runner_queue=None,
         tags=None,
     ):
         """
@@ -340,8 +339,6 @@ def record_and_warn(*args, **kwargs):
         self.paused = False
         self.paused_msg = ""
 
-        self.__runner_queue = runner_queue
-
         self.log.debug("Test metadata:")
         if self.filename:
             self.log.debug("  filename: %s", self.filename)
@@ -484,25 +481,6 @@ def cache_dirs(self):
             self.__cache_dirs = self._config.get("datadir.paths.cache_dirs")
         return self.__cache_dirs
 
-    @property
-    def runner_queue(self):
-        """
-        The communication channel between test and test runner
-        """
-        return self.__runner_queue
-
-    def set_runner_queue(self, runner_queue):
-        """
-        Override the runner_queue
-        """
-        if self.__runner_queue is not None:
-            raise RuntimeError(
-                f"Overriding of runner_queue multiple times "
-                f"is not allowed -> old={self.__runner_queue} "
-                f"new={runner_queue}"
-            )
-        self.__runner_queue = runner_queue
-
     @property
     def status(self):
         """
@@ -562,13 +540,6 @@ def _update_time_elapsed(self, current_time=None):
             current_time = time.monotonic()
         self.time_elapsed = current_time - self.time_start
 
-    def report_state(self):
-        """
-        Send the current test state to the test runner process
-        """
-        if self.runner_queue is not None:
-            self.runner_queue.put(self.get_state())
-
     def get_state(self):
         """
         Serialize selected attributes representing the test state