From: Michael Tremer Date: Sun, 23 Oct 2022 20:03:45 +0000 (+0000) Subject: daemon: Drop workers logger and use daemon logger X-Git-Tag: 0.9.28~230 X-Git-Url: http://git.ipfire.org/?a=commitdiff_plain;h=db1162a26a58f8dea437489afb980f90cab583e9;p=pakfire.git daemon: Drop workers logger and use daemon logger Signed-off-by: Michael Tremer --- diff --git a/src/pakfire/daemon.py b/src/pakfire/daemon.py index 7e06c3031..c6924c05f 100644 --- a/src/pakfire/daemon.py +++ b/src/pakfire/daemon.py @@ -173,11 +173,7 @@ class Daemon(object): self.log.debug("%s" % json.dumps(job, sort_keys=True, indent=4)) # Launch a new worker - worker = Worker( - self.hub, - job, - debug=self.debug, - ) + worker = Worker(self, job) self.workers.append(worker) # Run it @@ -187,21 +183,16 @@ class Daemon(object): class Worker(multiprocessing.Process): - def __init__(self, hub, data, debug=False): + def __init__(self, daemon, data): multiprocessing.Process.__init__(self) + self.daemon = daemon - self.hub = hub + self.hub = self.daemon.hub + self.log = self.daemon.log # The job that has been received self.data = data - # Setup a logger - self.log = logger.setup( - "pakfire.daemon.worker.%s" % self.pid, - level=logging.DEBUG if debug else logging.INFO, - syslog_identifier="pakfire-worker", - ) - def run(self): self.log.debug("Worker %s has launched" % self.pid)