feat(新功能):

fix(修复bug):   手动断开mq连接
docs(文档变更):
refactor(重构):
test(增加测试):
This commit is contained in:
zchengrong
2025-04-22 16:01:54 +08:00
parent 4dbb259b8b
commit f68b5a9f04
3 changed files with 3 additions and 0 deletions

View File

@@ -105,6 +105,7 @@ class GenerateMultiView:
dict_generate_data, str_generate_data = self.read_tasks_status()
if DEBUG is False:
self.channel.basic_publish(exchange='', routing_key=GMV_RABBITMQ_QUEUES, body=str_generate_data)
self.connection.close()
# self.channel.basic_publish(exchange='', routing_key=GI_RABBITMQ_QUEUES, body=str_generate_data)
logger.info(f" [x] Sent {json.dumps(dict_generate_data, indent=4)}")