diff --git a/webservice/job_monitor.py b/webservice/job_monitor.py index b451b3c950b836a8c9027b675d9e2c04353dbcf6..e0758ed17af131606c91bb2fb79f13d392296f6e 100644 --- a/webservice/job_monitor.py +++ b/webservice/job_monitor.py @@ -238,7 +238,7 @@ class JobsMonitor: return r['req_id'] def process_request_finished(self, req_id): - """Send notifications that a request has finished""" + """Send Kafka notifications and update myMDC that a request has finished.""" krb_id_successes = {r[0]: r[1] for r in self.job_db.execute( "SELECT karabo_id, success FROM executions WHERE req_id = ?", (req_id,)