DualFlow/models/uf-rl/uf_data_process/run_ufdata_pipeline.py

import os
import sys

SCRIPT_DIR = os.path.dirname(os.path.abspath(__file__))

from load import UFConfigLoader
from pipeline import UFAnalysisPipeline


def main():
    print("=====================================")
    print("    UF Multi-Unit Analysis Pipeline")
    print("=====================================")

    # 1. 加载配置文件
    config_path = os.path.join(SCRIPT_DIR, "uf_analyze_config.yaml")
    cfg = UFConfigLoader(config_path)

    # 2. 创建 pipeline
    pipeline = UFAnalysisPipeline(cfg)

    # 3. 执行 pipeline
    print(">>> Running pipeline ...")
    results = pipeline.run()

    print("=========================================")
    print("Pipeline finished. Results saved.")
    print("=========================================")


if __name__ == "__main__":
    main()