From bd2aeec5ebea904740c51691d2e51aa227a191e3 Mon Sep 17 00:00:00 2001
From: Simon Westphahl <simon.westphahl@bmw.de>
Date: Tue, 20 Jul 2021 09:54:12 +0200
Subject: [PATCH] Log result payload size of merger jobs

Change-Id: Ifb611c899edbc4978333a4da79248791816586cd
---
 zuul/merger/server.py | 21 +++++++++++++++++----
 1 file changed, 17 insertions(+), 4 deletions(-)

diff --git a/zuul/merger/server.py b/zuul/merger/server.py
index 6b4fd14ca0..e5a81e457c 100644
--- a/zuul/merger/server.py
+++ b/zuul/merger/server.py
@@ -16,6 +16,7 @@ import json
 import logging
 import os
 import socket
+import sys
 import threading
 from abc import ABCMeta
 from configparser import ConfigParser
@@ -188,7 +189,10 @@ class BaseMergeServer(metaclass=ABCMeta):
         else:
             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):
         self.log.debug("Got merge job: %s" % job.unique)
@@ -212,7 +216,10 @@ class BaseMergeServer(metaclass=ABCMeta):
             (result['commit'], result['files'], result['repo_state'],
              recent, orig_commit) = ret
         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):
         self.log.debug("Got refstate job: %s" % job.unique)
@@ -225,7 +232,10 @@ class BaseMergeServer(metaclass=ABCMeta):
                       repo_state=repo_state,
                       item_in_branches=item_in_branches)
         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):
         self.log.debug("Got fileschanges job: %s" % job.unique)
@@ -250,7 +260,10 @@ class BaseMergeServer(metaclass=ABCMeta):
             result = dict(updated=True, files=files)
 
         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):