diff --git a/prod_rmq_agents/task_manager.py b/prod_rmq_agents/task_manager.py index 210329edddce3ede73c04118278695ad5ad6bd91..9ef37ec936a211ea52a001b501d11d5a63d48935 100644 --- a/prod_rmq_agents/task_manager.py +++ b/prod_rmq_agents/task_manager.py @@ -266,7 +266,7 @@ def task_manager(ch, method, properties, body): # Send trigger message rc_rmq.publish_msg({"routing_key": routing_key, "msg": message}) - if task_name == "create_account" and success: + if task_name == "create_account" and success and rcfg.default_groups: rc_rmq.publish_msg( { "routing_key": "group_member.add",