Skip to content
Snippets Groups Projects
Commit 99fcad20 authored by Bo-Chun Chen's avatar Bo-Chun Chen
Browse files

Remove from tracking after report sent

parent 932758a6
No related branches found
No related tags found
Loading
...@@ -183,10 +183,15 @@ def task_manager(ch, method, properties, body): ...@@ -183,10 +183,15 @@ def task_manager(ch, method, properties, body):
logger.debug('Previous level messages acknowledged') logger.debug('Previous level messages acknowledged')
# Send report to admin after all tasks confirmed or terminated # Send report to admin
if completed or terminated: if completed or terminated:
notify_admin(username, current) notify_admin(username, current)
tracking.pop(username)
logger.debug('Admin report sent')
logger.info(f'Start listening to queue: {task}') logger.info(f'Start listening to queue: {task}')
rc_rmq.start_consume({ rc_rmq.start_consume({
......
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