Skip to content
Snippets Groups Projects
Commit 86e45dc8 authored by Eesaan Atluri's avatar Eesaan Atluri
Browse files

Adapt msg passing to fit task manager

parent 1abd8b72
No related branches found
No related tags found
6 merge requests!147Merge previous default branch feat-cod-rmq into main,!85kill nginx process running under user from login node,!51Fix acct create wait,!39WIP:Feat cod rmq,!38WIP: Feat cod rmq,!30Feat subscribe mail lists
...@@ -55,7 +55,8 @@ def mail_list_subscription(ch, method, properties, body): ...@@ -55,7 +55,8 @@ def mail_list_subscription(ch, method, properties, body):
logging.info(f'This email will add user {username} to {key}\n{email_msg}') logging.info(f'This email will add user {username} to {key}\n{email_msg}')
s.quit() s.quit()
success = True msg['task'] = task
msg['success'] = True
except Exception: except Exception:
logger.exception("Fatal error:") logger.exception("Fatal error:")
...@@ -66,10 +67,7 @@ def mail_list_subscription(ch, method, properties, body): ...@@ -66,10 +67,7 @@ def mail_list_subscription(ch, method, properties, body):
logger.debug('rc_rmq.publish_msg()') logger.debug('rc_rmq.publish_msg()')
rc_rmq.publish_msg({ rc_rmq.publish_msg({
'routing_key': 'confirm.' + username, 'routing_key': 'confirm.' + username,
'msg': { 'msg': msg
'task': task,
'success': success
}
}) })
logger.info('confirmation sent') logger.info('confirmation sent')
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment