From c8f050eac833aa03fad17775b7c14605b0a12867 Mon Sep 17 00:00:00 2001 From: puke <1129090915@qq.com> Date: Sun, 28 Dec 2025 16:34:01 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96FastAPI=E5=9C=BA=E6=99=AF?= =?UTF-8?q?=E7=9A=84runninghub=E5=B9=B6=E5=8F=91=E8=AE=BE=E7=BD=AE?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pixelle_video/pipelines/standard.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/pixelle_video/pipelines/standard.py b/pixelle_video/pipelines/standard.py index a7425c0..2cb88a2 100644 --- a/pixelle_video/pipelines/standard.py +++ b/pixelle_video/pipelines/standard.py @@ -301,8 +301,9 @@ class StandardPipeline(LinearVideoPipeline): (config.media_workflow and config.media_workflow.startswith("runninghub/")) ) - # Get concurrent limit from config (default to 1 for backward compatibility) - runninghub_concurrent_limit = self.core.config.get("comfyui", {}).get("runninghub_concurrent_limit", 1) + # Get concurrent limit from config_manager (supports hot reload without restart) + from pixelle_video.config import config_manager + runninghub_concurrent_limit = config_manager.config.comfyui.runninghub_concurrent_limit or 1 if is_runninghub and runninghub_concurrent_limit > 1: logger.info(f"🚀 Using parallel processing for RunningHub workflows (max {runninghub_concurrent_limit} concurrent)")