# step2_pipeline.py 내 시간 파싱부 변경 전:
# df_raw["timestamp_kst"] = df_raw["timestamp"] + pd.Timedelta(hours=9)
# df_raw["date"] = df_raw["timestamp_kst"].dt.strftime("%Y-%m-%d")
# ── 🌟 [변경 후] step1에서 이미 KST로 들어오므로 그대로 다이렉트 매핑 ──
df_raw["date"] = df_raw["timestamp"].dt.strftime("%Y-%m-%d")
# 하방 롤업 집계(groupby) 시에도 timestamp_kst 대신 원천 컬럼명 활용:
minutes_running = ("timestamp", "size")