Skip to content
Snippets Groups Projects
Commit 66fa1376 authored by Erik Reid's avatar Erik Reid
Browse files

added more info to standard response & status updates

parent 62fc55d4
No related branches found
No related tags found
No related merge requests found
...@@ -51,6 +51,8 @@ class InventoryTask(Task): ...@@ -51,6 +51,8 @@ class InventoryTask(Task):
def __init__(self): def __init__(self):
self.pid = os.getpid()
if InventoryTask.config: if InventoryTask.config:
return return
...@@ -69,6 +71,8 @@ class InventoryTask(Task): ...@@ -69,6 +71,8 @@ class InventoryTask(Task):
def update_state(self, **kwargs): def update_state(self, **kwargs):
meta = kwargs.setdefault('meta', dict()) meta = kwargs.setdefault('meta', dict())
meta['task'] = self.name meta['task'] = self.name
meta['worker'] = self.request.hostname
meta['pid'] = self.pid
logger.debug(json.dumps( logger.debug(json.dumps(
{'state': kwargs['state'], 'meta': str(meta)} {'state': kwargs['state'], 'meta': str(meta)}
)) ))
...@@ -87,6 +91,9 @@ class InventoryTask(Task): ...@@ -87,6 +91,9 @@ class InventoryTask(Task):
""" """
return { return {
'task': self.name, 'task': self.name,
'id': self.request.id,
'worker': self.request.hostname,
'pid': self.pid,
'warning': warning, 'warning': warning,
'message': message 'message': message
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment