| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455 |
- # schedulers/lnaive_scheduler.py
- from .lnaive_nb import naive_network_benchmarking_with_budget
- def lnaive_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)
- path_list = list(range(1, path_num + 1))
- if return_details:
- correctness, cost, best_path_fidelity, alloc_by_path, est_fid_by_path = \
- naive_network_benchmarking_with_budget(
- network, path_list, list(bounces), C_per_pair, 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 = naive_network_benchmarking_with_budget(
- network, path_list, list(bounces), C_per_pair
- )
- 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)
|
