let5see/AI-Video
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

统一RUNNING_HUB_PARALLEL_LIMIT控制逻辑

Browse Source
This commit is contained in:
puke
2025-11-20 14:42:59 +08:00
parent e2eac8798c
commit d3f4a675db
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pixelle_video/pipelines/standard.py
View File

@@ -41,9 +41,7 @@ from pixelle_video.utils.content_generators import (
) )
# Whether to enable parallel processing for RunningHub workflows # Parallel limit for RunningHub workflows (Call by sequential if set to 1)
RUNNING_HUB_PARALLEL_ENABLED = True
# Parallel limit for RunningHub workflows
RUNNING_HUB_PARALLEL_LIMIT = 1 RUNNING_HUB_PARALLEL_LIMIT = 1
@@ -379,7 +377,7 @@ class StandardPipeline(BasePipeline):
(config.image_workflow and config.image_workflow.startswith("runninghub/")) (config.image_workflow and config.image_workflow.startswith("runninghub/"))
) )
if is_runninghub and RUNNING_HUB_PARALLEL_ENABLED and RUNNING_HUB_PARALLEL_LIMIT > 1: if is_runninghub and RUNNING_HUB_PARALLEL_LIMIT > 1:
logger.info(f"🚀 Using parallel processing for RunningHub workflows (max {RUNNING_HUB_PARALLEL_LIMIT} concurrent)") logger.info(f"🚀 Using parallel processing for RunningHub workflows (max {RUNNING_HUB_PARALLEL_LIMIT} concurrent)")
logger.info(f" TTS: {'runninghub' if config.tts_workflow and config.tts_workflow.startswith('runninghub/') else 'local'}") logger.info(f" TTS: {'runninghub' if config.tts_workflow and config.tts_workflow.startswith('runninghub/') else 'local'}")
logger.info(f" Image: {'runninghub' if config.image_workflow and config.image_workflow.startswith('runninghub/') else 'local'}") logger.info(f" Image: {'runninghub' if config.image_workflow and config.image_workflow.startswith('runninghub/') else 'local'}")