diff --git a/prod_rmq_agents/acct_mgmt_workflow.py b/prod_rmq_agents/acct_mgmt_workflow.py index 7b7bc0cf7cb48ff9e045a918e8f599424a1c1a7a..fa1067ff900941903e02d515b84bf5fbe5db8f02 100755 --- a/prod_rmq_agents/acct_mgmt_workflow.py +++ b/prod_rmq_agents/acct_mgmt_workflow.py @@ -37,7 +37,7 @@ def manage_acct(ch, method, properties, body): msg["action"] = "unlock" else: print("Invalid state provided. Check the help menu.") - + if service == 'all': current["new_jobs"] = None current["expire_account"] = None @@ -54,7 +54,7 @@ def manage_acct(ch, method, properties, body): rc_rmq.publish_msg( { "routing_key": f"{each_service}.{queuename}", - "msg": msg + "msg": msg } ) @@ -71,7 +71,7 @@ def manage_acct(ch, method, properties, body): if done: rc_util.update_state(username, state) - + # Send done msg to account_manager.py rc_rmq.publish_msg( { 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} )