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

Adapt msg passing in bright account create to fit task manager

parent abc50481
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,!45Revert 29 feat add user bright cm,!39WIP:Feat cod rmq,!29Feat add user bright cm
...@@ -37,7 +37,8 @@ def bright_account_create(ch, method, properties, body): ...@@ -37,7 +37,8 @@ def bright_account_create(ch, method, properties, body):
if not args.dry_run: if not args.dry_run:
popen(cmd) popen(cmd)
logger.info(f'Bright command to create user:{cmd}') logger.info(f'Bright command to create user:{cmd}')
success = True msg['task'] = task
msg['success'] = True
except Exception: except Exception:
logger.exception("Fatal error:") logger.exception("Fatal error:")
...@@ -48,22 +49,10 @@ def bright_account_create(ch, method, properties, body): ...@@ -48,22 +49,10 @@ def bright_account_create(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')
if success:
# send create message to verify dir permissions agent
logger.debug(f'The task {task} finished successfully')
rc_rmq.publish_msg({
'routing_key': 'verify.' + username,
'msg': msg
})
logger.info('verify msg sent to next agent')
logger.info("Start listening to queue: {}".format(task)) logger.info("Start listening to queue: {}".format(task))
rc_rmq.start_consume({ rc_rmq.start_consume({
'queue': task, 'queue': task,
......
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