aidlab/AiDA_Python
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat:

Browse Source 
fix: 队列名修复
This commit is contained in:
zcr
2026-02-02 15:37:01 +08:00
parent 57be559cf2
commit c1b80c58f1
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
app/service/comfyui_I2V/pose2v_server.py
View File

@@ -13,7 +13,7 @@ from PIL import Image
from minio import Minio, S3Error from minio import Minio, S3Error
from moviepy.video.io.VideoFileClip import VideoFileClip from moviepy.video.io.VideoFileClip import VideoFileClip
from app.core.config import settings from app.core.config import settings, PS_RABBITMQ_QUEUES
from app.schemas.comfyui_i2v import ComfyuiPose2VModel from app.schemas.comfyui_i2v import ComfyuiPose2VModel
from app.service.generate_image.utils.mq import publish_status from app.service.generate_image.utils.mq import publish_status
@@ -622,9 +622,9 @@ class ComfyUIServerPose2V:
# 推送消息 # 推送消息
if not settings.DEBUG: if not settings.DEBUG:
publish_status(json.dumps(self.pose_transform_data), settings.COMFYUI_SERVER_ADDRESS) publish_status(json.dumps(self.pose_transform_data), PS_RABBITMQ_QUEUES)
logger.info( logger.info(
f" [x] Sent to： {settings.COMFYUI_SERVER_ADDRESS} data：@@@@ {json.dumps(self.pose_transform_data, indent=4)}") f" [x] Sent to： {PS_RABBITMQ_QUEUES} data：@@@@ {json.dumps(self.pose_transform_data, indent=4)}")
return "\n🎉 所有任务完成！" return "\n🎉 所有任务完成！"