From f88fc9d084febde163b6a605cd98811d353c8109 Mon Sep 17 00:00:00 2001
From: Thomas Kluyver <thomas@kluyver.me.uk>
Date: Thu, 23 Jun 2022 11:05:26 +0100
Subject: [PATCH] Convert run number back to string for Kafka messages
---
webservice/job_monitor.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/webservice/job_monitor.py b/webservice/job_monitor.py
index 3129cad48..f5af93309 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:
--
GitLab