opengnsys
/
ogagent
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refs #1105 include job_id in async responses

ogcore1
Natalia Serrano 2024-11-06 13:23:32 +01:00
parent b8733fea49
commit 6163c0b435
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/opengnsys/workers/oglive_worker.py
View File

@ -137,8 +137,9 @@ class ogLiveWorker(ServerWorker):
"Error desconocido", "Error desconocido",
] ]
def notifier (self, result): def notifier (self, job_id, result):
logger.debug (f'notifier() called, result ({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) res = self.REST.sendMessage ('clients/status/webhook', result)
def mon (self): def mon (self):
@ -155,7 +156,7 @@ class ogLiveWorker(ServerWorker):
elem['running'] = False elem['running'] = False
elem['result'] = elem['thread'].result ## race condition: KeyError: 'thread' elem['result'] = elem['thread'].result ## race condition: KeyError: 'thread'
del elem['thread'] del elem['thread']
self.notifier (elem['result']) self.notifier (k, elem['result'])
time.sleep (1) time.sleep (1)