Review mining related settings.

Indeed, the internal settings were too low.

Author: funilrys

PyFunceble/cli/processes/workers/base.py

@@ -77,8 +77,8 @@ class WorkerBase(multiprocessing.Process):
 
     STD_NAME: str = "pyfunceble_base_worker"
 
-    MINING_WAIT_TIME: int = 10
-    BREAKOFF: float = 0.5
+    MINING_WAIT_TIME: int = 60
+    BREAKOFF: float = 2.0
 
     input_queue: Optional[queue.Queue] = None
     output_queue: Optional[queue.Queue] = None

PyFunceble/cli/system/launcher.py

@@ -189,6 +189,7 @@ def __init__(self, args: Optional[argparse.Namespace] = None) -> None:
             continuous_integration=self.continuous_integration,
             daemon=True,
             output_workers_count=1,
+            output_queue_num=2,
         )
         self.producer_process_manager = ProducerProcessesManager(
             self.manager,
@@ -197,6 +198,7 @@ def __init__(self, args: Optional[argparse.Namespace] = None) -> None:
             input_queue=self.tester_process_manager.output_queue[0],
             daemon=True,
             output_workers_count=1,
+            generate_output_queue=True,
         )
         self.dir_files_sorter_process_manager = DirFileSorterProcessesManager(
             self.manager,
@@ -220,17 +222,14 @@ def __init__(self, args: Optional[argparse.Namespace] = None) -> None:
                 self.manager,
                 max_worker=1,
                 continuous_integration=self.continuous_integration,
+                input_queue=self.tester_process_manager.output_queue[1],
                 output_queue=self.tester_process_manager.input_queue,
+                generate_input_queue=False,
+                generate_output_queue=False,
                 daemon=True,
                 output_workers_count=self.tester_process_manager.max_worker,
             )
 
-            del self.producer_process_manager.output_queue
-
-            self.producer_process_manager.output_queue = [
-                self.miner_process_manager.input_queue
-            ]
-
         if self.continuous_integration.authorized:
             self.continuous_integration.set_start_time()