From 6163c0b435973bb7f3a8ce5d61062be6b5aa3008 Mon Sep 17 00:00:00 2001 From: Natalia Serrano Date: Wed, 6 Nov 2024 13:23:32 +0100 Subject: [PATCH] refs #1105 include job_id in async responses --- src/opengnsys/workers/oglive_worker.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/opengnsys/workers/oglive_worker.py b/src/opengnsys/workers/oglive_worker.py index cfc3318..599aba5 100644 --- a/src/opengnsys/workers/oglive_worker.py +++ b/src/opengnsys/workers/oglive_worker.py @@ -137,8 +137,9 @@ class ogLiveWorker(ServerWorker): "Error desconocido", ] - def notifier (self, result): - logger.debug (f'notifier() called, result ({result})') + def notifier (self, job_id, result): + logger.debug (f'notifier() called, job_id ({job_id}) result ({result})') + result['job_id'] = job_id res = self.REST.sendMessage ('clients/status/webhook', result) def mon (self): @@ -155,7 +156,7 @@ class ogLiveWorker(ServerWorker): elem['running'] = False elem['result'] = elem['thread'].result ## race condition: KeyError: 'thread' del elem['thread'] - self.notifier (elem['result']) + self.notifier (k, elem['result']) time.sleep (1)