Переглянути джерело

修改定时任务执行逻辑

xueyiming 1 тиждень тому
батько
коміт
3884dd5271

+ 1 - 1
jobs/run_supply_pipeline.py

@@ -1,5 +1,5 @@
 #!/usr/bin/env python3
 #!/usr/bin/env python3
-"""手动执行供应链数据流水线(全局树 → 需求池 → 分级)。"""
+"""手动执行供数据流水线(全局树 → 需求池 → 分级)。"""
 
 
 import logging
 import logging
 import sys
 import sys

+ 1 - 1
supply_infra/scheduler/constants.py

@@ -1,4 +1,4 @@
 """Scheduler job identifiers shared by app and job implementations."""
 """Scheduler job identifiers shared by app and job implementations."""
 
 
 SUPPLY_PIPELINE_JOB_ID = "run_supply_pipeline"
 SUPPLY_PIPELINE_JOB_ID = "run_supply_pipeline"
-SUPPLY_PIPELINE_JOB_NAME = "供应链数据流水线"
+SUPPLY_PIPELINE_JOB_NAME = "供数据流水线"

+ 1 - 1
supply_infra/scheduler/jobs/run_supply_pipeline.py

@@ -1,5 +1,5 @@
 """
 """
-串联执行的供应链数据流水线(可重复执行、幂等):
+串联执行的供数据流水线(可重复执行、幂等):
 
 
 1. ODPS → MySQL 全局树同步(T-1 分区)
 1. ODPS → MySQL 全局树同步(T-1 分区)
 2. ODPS → MySQL 策略需求池同步(当天 biz_dt)
 2. ODPS → MySQL 策略需求池同步(当天 biz_dt)