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)