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
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)