from data_juicer.config import init_configs
from data_juicer.core import DefaultExecutor
cfg = init_configs(args=["--config", "./video_pipeline_ray.yaml"])
executor = DefaultExecutor(cfg)
executor.run()