#!/usr/bin/env python3
"""手动执行供给数据流水线（全局树 → 需求池 → 分级 → 视频点位拓展）。"""

import logging
import sys

from supply_infra.scheduler.jobs.run_supply_pipeline import run_supply_pipeline

logging.basicConfig(
    level=logging.INFO,
    format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
)


def main() -> None:
    biz_dt = sys.argv[1] if len(sys.argv) > 1 else None
    result = run_supply_pipeline(biz_dt)
    print(result)


if __name__ == "__main__":
    main()
