zuul
/
zuul
Code Issues Proposed changes

Log result payload size of merger jobs 

Change-Id: Ifb611c899edbc4978333a4da79248791816586cd
This commit is contained in:
Simon Westphahl 2021-07-20 09:54:12 +02:00
parent 7e1e5a0176
commit bd2aeec5eb
1 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
zuul/merger/server.py
View File

@ -16,6 +16,7 @@ import json
import logging import logging
import os import os
import socket import socket
import sys
import threading import threading
from abc import ABCMeta from abc import ABCMeta
from configparser import ConfigParser from configparser import ConfigParser
@ -188,7 +189,10 @@ class BaseMergeServer(metaclass=ABCMeta):
else: else:
result = dict(updated=True, files=files) result = dict(updated=True, files=files)
job.sendWorkComplete(json.dumps(result)) payload = json.dumps(result)
self.log.debug("Completed cat job %s: payload size: %s",
job.unique, sys.getsizeof(payload))
job.sendWorkComplete(payload)
def merge(self, job): def merge(self, job):
self.log.debug("Got merge job: %s" % job.unique) self.log.debug("Got merge job: %s" % job.unique)
@ -212,7 +216,10 @@ class BaseMergeServer(metaclass=ABCMeta):
(result['commit'], result['files'], result['repo_state'], (result['commit'], result['files'], result['repo_state'],
recent, orig_commit) = ret recent, orig_commit) = ret
result['zuul_event_id'] = zuul_event_id result['zuul_event_id'] = zuul_event_id
job.sendWorkComplete(json.dumps(result)) payload = json.dumps(result)
self.log.debug("Completed merge job %s: payload size: %s",
job.unique, sys.getsizeof(payload))
job.sendWorkComplete(payload)
def refstate(self, job): def refstate(self, job):
self.log.debug("Got refstate job: %s" % job.unique) self.log.debug("Got refstate job: %s" % job.unique)
@ -225,7 +232,10 @@ class BaseMergeServer(metaclass=ABCMeta):
repo_state=repo_state, repo_state=repo_state,
item_in_branches=item_in_branches) item_in_branches=item_in_branches)
result['zuul_event_id'] = zuul_event_id result['zuul_event_id'] = zuul_event_id
job.sendWorkComplete(json.dumps(result)) payload = json.dumps(result)
self.log.debug("Completed refstate job %s: payload size: %s",
job.unique, sys.getsizeof(payload))
job.sendWorkComplete(payload)
def fileschanges(self, job): def fileschanges(self, job):
self.log.debug("Got fileschanges job: %s" % job.unique) self.log.debug("Got fileschanges job: %s" % job.unique)
@ -250,7 +260,10 @@ class BaseMergeServer(metaclass=ABCMeta):
result = dict(updated=True, files=files) result = dict(updated=True, files=files)
result['zuul_event_id'] = zuul_event_id result['zuul_event_id'] = zuul_event_id
job.sendWorkComplete(json.dumps(result)) payload = json.dumps(result)
self.log.debug("Completed fileschanges job %s: payload size: %s",
job.unique, sys.getsizeof(payload))
job.sendWorkComplete(payload)
class MergeServer(BaseMergeServer): class MergeServer(BaseMergeServer):