from data_juicer.config import init_configs
from data_juicer.core import ExecutorFactory
import sys

cfg_path = sys.argv[1] if len(sys.argv) > 1 else "./video_pipeline_ray.yaml"
cfg = init_configs(args=["--config", cfg_path])

executor_cls = ExecutorFactory.create_executor(cfg.executor_type)
print(">>> 执行器:", executor_cls.__name__)     # 必须打印 RayExecutor
executor_cls(cfg).run()