diff --git a/data_platform/daily_all_update.py b/data_platform/daily_all_update.py index e06c05ec..9f351379 100644 --- a/data_platform/daily_all_update.py +++ b/data_platform/daily_all_update.py @@ -669,6 +669,8 @@ def run_15min_update(codes: List[str]) -> dict: health = SourceHealthMonitor() for i, code in enumerate(todo): + if i < 3: + print(f"[DEBUG] 15min loop i={i} code={code}", flush=True) if source_aborted: break