shun-quantum-icc/new_add_linkselfie/schedulers/groups_scheduler.py

# schedulers/groups_scheduler.py
from .groups_nb import groups_network_benchmarking_with_budget

# 追加：重要度→グループ化
def _group_paths_by_importance(path_num: int, importance: float):
    """
    重要度に応じて実リンクID(1..L)をグループ化した二次元配列を返す。
      0.75 < I <= 1.00 : まとめない（[ [1], [2], ..., [L] ]）
      0.50 < I <= 0.75 : 2本ずつ（余りは小グループでOK）
      0.25 < I <= 0.50 : 3本ずつ（余りは小グループでOK）
      0.00 < I <= 0.25 : 全部まとめる（[ [1,2,...,L] ]）
    """
    L = int(path_num)
    ids = list(range(1, L + 1))
    I = float(importance)

    if I > 0.75:
        return [[i] for i in ids]

    if I > 0.50:
        size = 2
    elif I > 0.25:
        size = 3
    else:
        return [ids]  # 全まとめ

    groups = []
    for i in range(0, L, size):
        groups.append(ids[i:i+size])
    return groups


def groups_budget_scheduler(
    node_path_list,      # 例: [2, 2, 2] … 各ペアのパス本数
    importance_list,     # 例: [0.3, 0.5, 0.7] … 長さは node_path_list と同じ（ここでは未使用）
    bounces,             # 例: [1,2,3,4]（重複なし）
    C_total,             # 総予算（切り捨て配分、超過しない）
    network_generator,   # callable: (path_num, pair_idx) -> network
    return_details=False,
):
    num_pairs = len(node_path_list)
    assert num_pairs == len(importance_list), "length mismatch: node_path_list vs importance_list"
    if num_pairs == 0:
        return ([], 0, []) if return_details else ([], 0)

    assert len(bounces) == len(set(bounces)), "bounces must be unique"
    assert all(isinstance(w, int) and w > 0 for w in bounces), "bounces must be positive ints"

    # 均等配分：1ペアあたりの割当
    C_per_pair = int(C_total // max(num_pairs, 1))

    per_pair_results = []
    per_pair_details = []
    total_cost = 0

    for pair_idx, path_num in enumerate(node_path_list):
        if path_num <= 0:
            per_pair_results.append((False, 0, None))
            if return_details:
                per_pair_details.append({"alloc_by_path": {}, "est_fid_by_path": {}})
            continue

        network = network_generator(path_num, pair_idx)
        # 追加：重要度に応じたグループ
        groups = _group_paths_by_importance(path_num, importance_list[pair_idx])


        path_list = list(range(1, path_num + 1))

        if return_details:
            correctness, cost, best_path_fidelity, alloc_by_path, est_fid_by_path = \
                groups_network_benchmarking_with_budget(
                    network, path_list, list(bounces), C_per_pair, groups=groups, return_details=True
                )
            per_pair_details.append({
                "alloc_by_path": {int(k): int(v) for k, v in alloc_by_path.items()},
                "est_fid_by_path": {int(k): float(v) for k, v in est_fid_by_path.items()},
            })
        else:
            correctness, cost, best_path_fidelity = groups_network_benchmarking_with_budget(
                network, path_list, list(bounces), C_per_pair, groups=groups,
            )

        per_pair_results.append((bool(correctness), int(cost), best_path_fidelity))
        total_cost += int(cost)

    return (per_pair_results, total_cost, per_pair_details) if return_details \
           else (per_pair_results, total_cost)