Add some gearman related debugging

Make sure all clients are identified.
Log the port on which the gearman server is listening in tests.
Log the arguments for the launch job.

Change-Id: Ia99ea5272241799aa8dd089bdb99f6058838ddff
This commit is contained in:
James E. Blair 2017-02-02 17:19:40 -08:00
parent 096c5cdba5
commit e47eb770dd
4 changed files with 6 additions and 2 deletions

View File

@ -1239,6 +1239,8 @@ class ZuulTestCase(BaseTestCase):
self.gearman_server = FakeGearmanServer()
self.config.set('gearman', 'port', str(self.gearman_server.port))
self.log.info("Gearman server on port %s" %
(self.gearman_server.port,))
gerritsource.GerritSource.replication_timeout = 1.5
gerritsource.GerritSource.replication_retry_interval = 0.5

View File

@ -98,7 +98,7 @@ def getJobData(job):
class ZuulGearmanClient(gear.Client):
def __init__(self, zuul_gearman):
super(ZuulGearmanClient, self).__init__()
super(ZuulGearmanClient, self).__init__('Zuul Launch Client')
self.__zuul_gearman = zuul_gearman
def handleWorkComplete(self, packet):

View File

@ -462,6 +462,8 @@ class AnsibleJob(object):
def _launch(self):
self.log.debug("Job %s: beginning" % (self.job.unique,))
self.log.debug("Job %s: args: %s" % (self.job.unique,
self.job.arguments,))
self.log.debug("Job %s: job root at %s" %
(self.job.unique, self.jobdir.root))
args = json.loads(self.job.arguments)

View File

@ -33,7 +33,7 @@ def getJobData(job):
class MergeGearmanClient(gear.Client):
def __init__(self, merge_client):
super(MergeGearmanClient, self).__init__()
super(MergeGearmanClient, self).__init__('Zuul Merge Client')
self.__merge_client = merge_client
def handleWorkComplete(self, packet):