vbatts/quay
Archived
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Add active worker count to buildmanager logs.

Browse source
This commit is contained in:
Jimmy Zelinskie 2014-12-16 13:37:40 -05:00
parent 37079315d2
commit 33f12c58ba
3 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
buildman/manager/basemanager.py
View file

@ -47,3 +47,9 @@ class BaseManager(object):
one of: incomplete, error, complete. If incomplete, the job should be requeued. one of: incomplete, error, complete. If incomplete, the job should be requeued.
""" """
raise NotImplementedError raise NotImplementedError
def num_workers(self):
""" Returns the number of active build workers currently registered. This includes those
that are currently busy and awaiting more work.
"""
raise NotImplementedError

2
buildman/manager/enterprise.py
View file

@ -70,3 +70,5 @@ class EnterpriseManager(BaseManager):
def build_component_disposed(self, build_component, timed_out): def build_component_disposed(self, build_component, timed_out):
self.build_components.remove(build_component) self.build_components.remove(build_component)
def num_workers(self):
return len(self.build_components)

4
buildman/server.py
View file

@ -9,7 +9,7 @@ from aiowsgi import create_server as create_wsgi_server
from flask import Flask from flask import Flask
from threading import Event from threading import Event
from trollius.coroutines import From from trollius.coroutines import From
from datetime import datetime, timedelta from datetime import timedelta
from buildman.jobutil.buildjob import BuildJob, BuildJobLoadException from buildman.jobutil.buildjob import BuildJob, BuildJobLoadException
from data.queue import WorkQueue from data.queue import WorkQueue
@ -137,7 +137,7 @@ class BuilderServer(object):
@trollius.coroutine @trollius.coroutine
def _work_checker(self): def _work_checker(self):
while self._current_status == 'running': while self._current_status == 'running':
logger.debug('Checking for more work') logger.debug('Checking for more work for %d active workers', self._lifecycle_manager.num_workers())
job_item = self._queue.get(processing_time=self._lifecycle_manager.setup_time()) job_item = self._queue.get(processing_time=self._lifecycle_manager.setup_time())
if job_item is None: if job_item is None:
logger.debug('No additional work found. Going to sleep for %s seconds', WORK_CHECK_TIMEOUT) logger.debug('No additional work found. Going to sleep for %s seconds', WORK_CHECK_TIMEOUT)