mirror of
https://github.com/avatao-content/baseimage-tutorial-framework
synced 2024-11-23 00:11:33 +00:00
Extend ProcessManagingEventHander with deployment failure detection
This commit is contained in:
parent
d11d9a70cb
commit
9b550f724d
@ -1,4 +1,5 @@
|
|||||||
from functools import wraps
|
from functools import wraps
|
||||||
|
from xmlrpc.client import Fault as SupervisorFault
|
||||||
|
|
||||||
from tfw.event_handler_base import TriggerlessEventHandler
|
from tfw.event_handler_base import TriggerlessEventHandler
|
||||||
from tfw.components.mixins import SupervisorMixin
|
from tfw.components.mixins import SupervisorMixin
|
||||||
@ -37,6 +38,11 @@ class ProcessManagingEventHandler(TriggerlessEventHandler):
|
|||||||
try:
|
try:
|
||||||
data = data_json['data']
|
data = data_json['data']
|
||||||
self.processmanager(data['command'], data['process_name'])
|
self.processmanager(data['command'], data['process_name'])
|
||||||
|
data_json['data']['error'] = False
|
||||||
return data_json
|
return data_json
|
||||||
except KeyError:
|
except KeyError:
|
||||||
log.error('IGNORING MESSAGE: Invalid data_json received: {}'.format(data_json))
|
log.error('IGNORING MESSAGE: Invalid data_json received: {}'.format(data_json))
|
||||||
|
except SupervisorFault:
|
||||||
|
data_json['data']['error'] = True
|
||||||
|
log.debug('Failed to execute command on process: {}'.format(data_json))
|
||||||
|
return data_json
|
||||||
|
Loading…
Reference in New Issue
Block a user