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

Move message acknowledge to the end

parent 787c960e
No related branches found
No related tags found
8 merge requests!147Merge previous default branch feat-cod-rmq into main,!85kill nginx process running under user from login node,!51Fix acct create wait,!44WIP: Update Feat task manager to match new messaging structure,!39WIP:Feat cod rmq,!38WIP: Feat cod rmq,!34WIP: Update task manager agent,!25Feature task manager
...@@ -97,13 +97,6 @@ def task_manager(ch, method, properties, body): ...@@ -97,13 +97,6 @@ def task_manager(ch, method, properties, body):
logger.error('', exc_info=True) logger.error('', exc_info=True)
if done: if done:
# Acknowledge all message from last level
for tag in current['delivery_tags']:
ch.basic_ack(tag)
current['delivery_tags'] = []
logger.debug('Previous level messages acknowledged')
# Send trigger message # Send trigger message
rc_rmq.publish_msg({ rc_rmq.publish_msg({
'routing_key': routing_key, 'routing_key': routing_key,
...@@ -117,6 +110,13 @@ def task_manager(ch, method, properties, body): ...@@ -117,6 +110,13 @@ def task_manager(ch, method, properties, body):
logger.debug(f"Trigger message '{routing_key}' sent") logger.debug(f"Trigger message '{routing_key}' sent")
# Acknowledge all message from last level
for tag in current['delivery_tags']:
ch.basic_ack(tag)
current['delivery_tags'] = []
logger.debug('Previous level messages acknowledged')
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