From e425b1d822fff4b1ac29f93251eaa4e68f38940c Mon Sep 17 00:00:00 2001 From: Bo-Chun Louis Chen <louistw@uab.edu> Date: Thu, 14 Mar 2024 21:35:05 -0500 Subject: [PATCH] Send additional info to group member agent --- group_manager.py | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/group_manager.py b/group_manager.py index b2485a3..66440b7 100755 --- a/group_manager.py +++ b/group_manager.py @@ -2,14 +2,13 @@ import argparse import grp import json -import os import pika import pwd import rabbit_config as rcfg import sys import uuid from rc_rmq import RCRMQ -from rc_util import timeout +from rc_util import get_caller_info, timeout # Instantiate rabbitmq object @@ -40,6 +39,9 @@ def manage_group(op, usernames, groupname, debug=False): status = dict.fromkeys(usernames, False) response = 0 + interface = "CLI" + executed_by, host = get_caller_info() + def handler(ch, method, properties, body): if debug: print("Message received:") @@ -75,6 +77,9 @@ def manage_group(op, usernames, groupname, debug=False): "msg": { "groups": {f"{op}": [f"{groupname}"]}, "username": user, + "host": host, + "executed_by": executed_by, + "interface": interface, }, } ) @@ -109,8 +114,6 @@ if __name__ == "__main__": ) args = parser.parse_args() - executed_by = os.getenv("USER") - exist_users = [] miss = False -- GitLab