diff --git a/prod_rmq_agents/group_member.py b/prod_rmq_agents/group_member.py index cda7e5ac0bdf97f4ef953cc4b3fde4951b65143f..c0d2f7e791e8fa06375abccf503de62f2af88a12 100644 --- a/prod_rmq_agents/group_member.py +++ b/prod_rmq_agents/group_member.py @@ -94,5 +94,4 @@ rc_rmq.start_consume( ) logger.info("Disconnected") -rc_rmq.disconnect() - +rc_rmq.disconnect() \ No newline at end of file diff --git a/prod_rmq_agents/new_jobs.py b/prod_rmq_agents/new_jobs.py index cb51d18e4f21e77abe2d1391724ca18b474a8727..2d3280defec66f67f9c45a8e25412327a2f14df8 100644 --- a/prod_rmq_agents/new_jobs.py +++ b/prod_rmq_agents/new_jobs.py @@ -43,7 +43,7 @@ def new_jobs(ch, method, properties, body): rc_rmq.publish_msg( - {"routing_key": f'acctmgr.done.{queuename}', + {"routing_key": f'acctmgr.done.{queuename}', "msg": msg} ) diff --git a/prod_rmq_agents/ssh_access.py b/prod_rmq_agents/ssh_access.py index 947d66a89077d4eb327955beaa1b1561a33ef2c0..91b0cbf11baaab2beac9cea8252e6fa26c7248dc 100644 --- a/prod_rmq_agents/ssh_access.py +++ b/prod_rmq_agents/ssh_access.py @@ -42,7 +42,6 @@ def ssh_access(ch, method, properties, body): } ) logger.debug(f'User {username} confirmation sent for {action}ing {task}') - else: corr_id = str(uuid.uuid4()) logger.debug(f'corr_id generated: {corr_id}')