diff --git a/webservice/job_monitor.py b/webservice/job_monitor.py
index 3129cad48b1b52277b0890e64e3bd8812ef49de4..f5af933090ccfd6d865dd9c0009f7ad440a11643 100644
--- a/webservice/job_monitor.py
+++ b/webservice/job_monitor.py
@@ -226,7 +226,7 @@ class JobsMonitor:
                 self.kafka_prod.send(self.kafka_topic, {
                     'event': 'correction_complete',
                     'proposal': r['proposal'],
-                    'run': r['run'],
+                    'run': str(r['run']),
                     'detector': r['det_type'],
                     'detector_installation': r['karabo_id'],
                     'success': success,
@@ -257,7 +257,7 @@ class JobsMonitor:
                 self.kafka_prod.send(self.kafka_topic, {
                     'event': 'run_corrections_complete',
                     'proposal': r['proposal'],
-                    'run': r['run'],
+                    'run': str(r['run']),
                     'success': success,
                 })
             except KafkaError: