From 66fa13769d0cb6d7ffdc050b6aebd1dd7ba169c5 Mon Sep 17 00:00:00 2001
From: Erik Reid <erik.reid@geant.org>
Date: Sat, 9 May 2020 12:36:10 +0200
Subject: [PATCH] added more info to standard response & status updates
---
inventory_provider/tasks/worker.py | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py
index bb09fffd..93346262 100644
--- a/inventory_provider/tasks/worker.py
+++ b/inventory_provider/tasks/worker.py
@@ -51,6 +51,8 @@ class InventoryTask(Task):
def __init__(self):
+ self.pid = os.getpid()
+
if InventoryTask.config:
return
@@ -69,6 +71,8 @@ class InventoryTask(Task):
def update_state(self, **kwargs):
meta = kwargs.setdefault('meta', dict())
meta['task'] = self.name
+ meta['worker'] = self.request.hostname
+ meta['pid'] = self.pid
logger.debug(json.dumps(
{'state': kwargs['state'], 'meta': str(meta)}
))
@@ -87,6 +91,9 @@ class InventoryTask(Task):
"""
return {
'task': self.name,
+ 'id': self.request.id,
+ 'worker': self.request.hostname,
+ 'pid': self.pid,
'warning': warning,
'message': message
}
--
GitLab