"""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