SupplyAgent/supply_infra/scheduler/constants.py

"""Scheduler job identifiers shared by app and job implementations."""

SUPPLY_PIPELINE_JOB_ID = "run_supply_pipeline"
SUPPLY_PIPELINE_JOB_NAME = "供给数据流水线"

# AIGC：独立轮询，发现未发布的 primary 候选后分发
AIGC_PUBLISH_JOB_ID = "publish_videos_from_discovery"
AIGC_PUBLISH_JOB_NAME = "AIGC候选分发"

# find_agent：当日全部 S/A 需求（有拓展点位），单线程串行找视频
PIPELINE_FIND_AGENT_WORKERS = 1