mirror of
https://github.com/frappe/gunicorn.git
synced 2026-01-14 11:09:11 +08:00
Merge pull request #1078 from preo/reduce-arbiter-noise
Only log '[num] workers' message when it changes.
This commit is contained in:
commit
a132ca97c8
@ -55,6 +55,8 @@ class Arbiter(object):
|
|||||||
os.environ["SERVER_SOFTWARE"] = SERVER_SOFTWARE
|
os.environ["SERVER_SOFTWARE"] = SERVER_SOFTWARE
|
||||||
|
|
||||||
self._num_workers = None
|
self._num_workers = None
|
||||||
|
self._last_logged_active_worker_count = None
|
||||||
|
|
||||||
self.setup(app)
|
self.setup(app)
|
||||||
|
|
||||||
self.pidfile = None
|
self.pidfile = None
|
||||||
@ -482,10 +484,13 @@ class Arbiter(object):
|
|||||||
(pid, _) = workers.pop(0)
|
(pid, _) = workers.pop(0)
|
||||||
self.kill_worker(pid, signal.SIGTERM)
|
self.kill_worker(pid, signal.SIGTERM)
|
||||||
|
|
||||||
self.log.debug("{0} workers".format(len(workers)),
|
active_worker_count = len(workers)
|
||||||
extra={"metric": "gunicorn.workers",
|
if self._last_logged_active_worker_count != active_worker_count:
|
||||||
"value": len(workers),
|
self._last_logged_active_worker_count = active_worker_count
|
||||||
"mtype": "gauge"})
|
self.log.debug("{0} workers".format(active_worker_count),
|
||||||
|
extra={"metric": "gunicorn.workers",
|
||||||
|
"value": active_worker_count,
|
||||||
|
"mtype": "gauge"})
|
||||||
|
|
||||||
def spawn_worker(self):
|
def spawn_worker(self):
|
||||||
self.worker_age += 1
|
self.worker_age += 1
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user