26J30h1a

# df_raw["workload_type"] = df_raw["pod"].apply(get_workload_type) 구문 하단에 삽입

    print("🧩 [카디널리티 억제] 스파크/에어플로우 동적 휘발성 팟 이름 단일화 마스킹 중...")
    # 💡 핵심: 정적 유일 이름으로 치환하여 groupby 시 자동으로 하나의 풀(Pool)로 압축 수렴되도록 유도
    df_raw["pod"] = np.where(df_raw["workload_type"] == "SPARK_EXECUTOR", "spark-executor-pool", df_raw["pod"])
    df_raw["pod"] = np.where(df_raw["workload_type"] == "AIRFLOW_WORKER", "airflow-worker-pool", df_raw["pod"])
    
    df_raw["container"] = np.where(df_raw["workload_type"] == "SPARK_EXECUTOR", "executor", df_raw["container"])
    df_raw["container"] = np.where(df_raw["workload_type"] == "AIRFLOW_WORKER", "worker", df_raw["container"])

    # 이후 기존 groupby 구문은 수정 없이 그대로 가동
    # print("📊 고정밀 시계열 기반 팟 단위 리밸런싱 집계 가동...")
    # df_pod = df_raw.groupby(["date", "cluster", "cluster_type", "namespace", "workload_type", "node", "pod", "container"]).agg(...