diff --git a/prod_rmq_agents/group_member.py b/prod_rmq_agents/group_member.py index cda7e5ac0bdf97f4ef953cc4b3fde4951b65143f..d09c0278e2774d0a4286be024c2912e6125ddff6 100644 --- a/prod_rmq_agents/group_member.py +++ b/prod_rmq_agents/group_member.py @@ -1,11 +1,9 @@ #!/usr/bin/env python -import os import json import pika import shlex import rc_util from subprocess import Popen,PIPE -from pathlib import Path from rc_rmq import RCRMQ import rabbit_config as rcfg @@ -21,9 +19,7 @@ rc_rmq = RCRMQ({"exchange": rcfg.Exchange, "exchange_type": "topic"}) def group_member(ch, method, properties, body): msg = json.loads(body) username = msg["username"] - action = msg["action"] msg["task"] = task - state = msg["state"] try: if 'remove' in msg["groups"]: