Removed Queue logging handler (#67)

Author: s3rius

.github/workflows/test.yml

@@ -56,5 +56,5 @@ jobs:
         if: matrix.os == 'ubuntu-latest' && matrix.py_version == '3.9'
         with:
           token: ${{ secrets.CODECOV_TOKEN }}
-          fail_ci_if_error: true
+          fail_ci_if_error: false
           verbose: true

taskiq/cli/worker/process_manager.py

@@ -75,6 +75,7 @@ def handle(
             daemon=True,
         )
         new_process.start()
+        logger.info(f"Process {new_process.name} restarted with pid {new_process.pid}")
         workers[self.worker_num] = new_process
 
 
@@ -163,12 +164,12 @@ def prepare_workers(self) -> None:
                 name=f"worker-{process}",
                 daemon=True,
             )
+            work_proc.start()
             logger.info(
                 "Started process worker-%d with pid %s ",
                 process,
                 work_proc.pid,
             )
-            work_proc.start()
             self.workers.append(work_proc)
 
     def start(self) -> None:  # noqa: C901, WPS213

taskiq/cli/worker/run.py

@@ -1,9 +1,6 @@
 import asyncio
 import logging
 import signal
-import sys
-from logging.handlers import QueueHandler, QueueListener
-from multiprocessing import Queue
 from typing import Any
 
 from watchdog.observers import Observer
@@ -120,15 +117,11 @@ def run_worker(args: WorkerArgs) -> None:  # noqa: WPS213
 
     :param args: CLI arguments.
     """
-    logging_queue = Queue(-1)  # type: ignore
-    listener = QueueListener(logging_queue, logging.StreamHandler(sys.stdout))
     logging.basicConfig(
         level=logging.getLevelName(args.log_level),
         format="[%(asctime)s][%(name)s][%(levelname)-7s][%(processName)s] %(message)s",
-        handlers=[QueueHandler(logging_queue)],
     )
     logging.getLogger("watchdog.observers.inotify_buffer").setLevel(level=logging.INFO)
-    listener.start()
     logger.info("Starting %s worker processes.", args.workers)
 
     observer = Observer()
@@ -149,4 +142,3 @@ def run_worker(args: WorkerArgs) -> None:  # noqa: WPS213
             logger.info("Stopping watching files.")
         observer.stop()
     logger.info("Stopping logging thread.")
-    listener.stop()