diff --git a/account_manager.py b/account_manager.py
index 709f5dba7f0c12ca5269337e514552ef817448f1..3e9632d10fe86006ef1ae380fb30c10e2105473e 100755
--- a/account_manager.py
+++ b/account_manager.py
@@ -40,7 +40,7 @@ msg["username"] = username
 msg["state"] = state
 msg["service"] = service
 msg["queuename"] = queuename
-msg["updated_by"] = rc_util.get_caller_info()
+msg["updated_by"], msg["host"] = rc_util.get_caller_info()
 
 # publish msg with acctmgr.{uname} routing key.
 rc_rmq.publish_msg(
diff --git a/create_account.py b/create_account.py
index 9e834b662384914a4cf47dfc37d5ff5bdde79a30..42668c36a52677d9998601266ed999bd08ba6d77 100755
--- a/create_account.py
+++ b/create_account.py
@@ -25,7 +25,7 @@ args = parser.parse_args()
 timeout = 60
 
 queuename = rc_util.encode_name(args.username)
-updated_by = rc_util.get_caller_info()
+updated_by, host = rc_util.get_caller_info()
 
 if args.email == "":
     args.email = args.username
@@ -60,6 +60,7 @@ rc_util.add_account(
     full=args.full_name,
     reason=args.reason,
     updated_by=updated_by,
+    host=host,
 )
 print(f"Account for {args.username} requested.")
 
diff --git a/init_user_state.py b/init_user_state.py
index 8d5c6084e9b18067f590f513591ddbdfa0d47a24..54ba947560e151fa12592d7f314bb5b916a1ccb4 100644
--- a/init_user_state.py
+++ b/init_user_state.py
@@ -16,7 +16,7 @@ args = parser.parse_args()
 
 default_state = "ok"
 today = datetime.now()
-updated_by = rc_util.get_caller_info()
+updated_by, host = rc_util.get_caller_info()
 
 # Chunk size for insert into db
 size = 1000
@@ -45,6 +45,7 @@ if len(users) > 50:
                 state=default_state,
                 date=today,
                 updated_by=updated_by,
+                host=host,
             )
             for user in users[start:end]
         ]
@@ -66,5 +67,6 @@ else:
                     "state": default_state,
                     "date": today,
                     "updated_by": updated_by,
+                    "host": host,
                 }
             )
diff --git a/prod_rmq_agents/acct_mgmt_workflow.py b/prod_rmq_agents/acct_mgmt_workflow.py
index 3f39736e5c168bf67c9a0dcfab82c9dad9b8ecaa..922d802f77f285ad7a748789463bb7a41f8143a3 100755
--- a/prod_rmq_agents/acct_mgmt_workflow.py
+++ b/prod_rmq_agents/acct_mgmt_workflow.py
@@ -70,7 +70,9 @@ def manage_acct(ch, method, properties, body):
                 done = False
 
         if done:
-            rc_util.update_state(username, state, msg.get("updated_by"))
+            rc_util.update_state(
+                username, state, msg.get("updated_by"), msg.get("host")
+            )
 
             # Send done msg to account_manager.py
             rc_rmq.publish_msg(
diff --git a/prod_rmq_agents/task_manager.py b/prod_rmq_agents/task_manager.py
index 57d03058e93510ebce82944d49ff34d890dc1509..3b82f838f47ed8b926bb3ecc3b506ea59bb26fdf 100644
--- a/prod_rmq_agents/task_manager.py
+++ b/prod_rmq_agents/task_manager.py
@@ -277,7 +277,9 @@ def task_manager(ch, method, properties, body):
 
         update_db(username, {"reported": True})
 
-        rc_util.update_state(username, "ok", msg.get("updated_by"))
+        rc_util.update_state(
+            username, "ok", msg.get("updated_by"), msg.get("host")
+        )
 
         tracking.pop(username)
 
diff --git a/prod_rmq_agents/user_state.py b/prod_rmq_agents/user_state.py
index f9b74a1071675f4da70cb17d7d34d01ad4176776..208af16b4b68886161c79683f92ad77ab01df8e3 100644
--- a/prod_rmq_agents/user_state.py
+++ b/prod_rmq_agents/user_state.py
@@ -23,6 +23,7 @@ def user_state(ch, method, properties, body):
     msg = json.loads(body)
     username = msg["username"]
     updated_by = msg.get("updated_by")
+    host = msg.get("host")
     op = msg["op"]
     msg["success"] = False
     errmsg = ""
@@ -53,6 +54,7 @@ def user_state(ch, method, properties, body):
                     "state": state,
                     "date": datetime.now(),
                     "updated_by": updated_by,
+                    "host": host,
                 }
             )
             logger.debug(f"User {username} state updates to {state}")