Merge pull request #143 from phenobarbital/queue-manager

fixing logger name from some workers processes

qw/client.py

@@ -85,7 +85,7 @@ def __init__(self, worker_list: list = None, timeout: int = 5):
         except RuntimeError:
             raise
         ## logger:
-        self.logger = logging.getLogger('QW:Client')
+        self.logger = logging.getLogger('QW.Client')
         ## check if we use network discovery or redis list:
         if worker_list:
             self._workers = worker_list

qw/decorators.py

@@ -5,8 +5,9 @@
 
 
 def dispatch(func: Callable) -> Any:
-    qw = QClient() ## calling Queue Worker
+    qw = QClient()  # calling Queue Worker
     print('FUNCTION is ', qw)
+
     @wraps(func)
     async def _wrap(*args, **kwargs):
         result = await qw.queue(func, *args, **kwargs)

qw/executor/__init__.py

@@ -7,7 +7,7 @@
 
 class TaskExecutor:
     def __init__(self, task, *args, **kwargs):
-        self.logger = logging.getLogger('QS.Executor')
+        self.logger = logging.getLogger('QW.Executor')
         self.task = task
         self.semaphore = asyncio.Semaphore(WORKER_CONCURRENCY_NUMBER)
 

qw/process.py

@@ -69,7 +69,7 @@ def __init__(self, args):
         raise_nofile(value=NOFILES)
         ## Logger:
         self.logger = logging.getLogger(
-            name='QW:WorkerProcess'
+            name='QW.WorkerProcess'
         )
         for i in range(args.workers):
             try:

qw/protocols.py

@@ -34,7 +34,7 @@ def __init__(self):
             raise QWException(
                 f"Error getting event loop: {ex}"
             )
-        self.logger = logging.getLogger('QW:Discovery')
+        self.logger = logging.getLogger('QW.Discovery')
         self.transport = None
         super().__init__()
 
@@ -86,7 +86,7 @@ class QueueProtocol(asyncio.Protocol):
     def __init__(self, queue: asyncio.Queue, name: str):
         self.queue = queue
         self.logger = logging.getLogger(
-            f'QW:QueueServer-{name}'
+            f'QW.QueueServer-{name}'
         )
         self.transport = None
         self.loop = asyncio.get_event_loop()

qw/server.py

@@ -75,7 +75,7 @@ def __init__(
         self._protocol = protocol
         # logging:
         self.logger = logging.getLogger(
-            f'QW:Server:{self._name}:{self._id}'
+            f'QW.Server:{self._name}.{self._id}'
         )
 
     @property

qw/version.py

@@ -6,7 +6,7 @@
 __description__ = ('QueueWorker is asynchronous Task Queue implementation '
                    'built on top of Asyncio.'
                    'Can you spawn distributed workers to run functions inside workers.')
-__version__ = '1.8.0'
+__version__ = '1.8.1'
 __author__ = 'Jesus Lara'
 __author_email__ = 'jesuslarag@gmail.com'
 __license__ = 'MIT'