2023-08-21 03:33:46 +02:00

338 lines
10 KiB
Python

# Copyright (c) 2023 ETH Zurich.
# All rights reserved.
#
# Use of this source code is governed by a BSD-style license that can be
# found in the LICENSE file.
#
# main author: Nils Blach
# contributions: Robert Gerstenberger
import json
import os
import matplotlib.pyplot as plt
def get_complete_results(base_directory):
results_complete = {}
for folder_name in os.listdir(base_directory):
folder_path = os.path.join(base_directory, folder_name)
if os.path.isdir(folder_path):
results_complete[folder_name] = []
for file_name in os.listdir(folder_path):
if file_name.endswith(".json"):
file_path = os.path.join(folder_path, file_name)
with open(file_path, "r") as f:
data = json.load(f)
results_complete[folder_name].append(
{"key": int(file_name.split(".")[0]), "data": data}
)
for key in results_complete.keys():
results_complete[key] = sorted(
results_complete[key], key=lambda x: x["key"]
)
return results_complete
def get_final_scores(results_complete):
scores = {}
for method in results_complete.keys():
scores[method] = []
for result in results_complete[method]:
score = 100
solved = False
cost = 1
prompt_tokens = 0
completion_tokens = 0
for op in result["data"]:
if "operation" in op and op["operation"] == "ground_truth_evaluator":
try:
score = min(op["scores"])
solved = any(op["problem_solved"])
except:
continue
if "cost" in op:
cost = op["cost"]
prompt_tokens = op["prompt_tokens"]
completion_tokens = op["completion_tokens"]
scores[method].append(
[result["key"], score, solved, prompt_tokens, completion_tokens, cost]
)
scores[method] = sorted(scores[method], key=lambda x: x[0])
return scores
def get_final_scores_doc_merge(results_complete):
scores = {}
for method in results_complete.keys():
scores[method] = []
for result in results_complete[method]:
score = 0
solved = False
cost = 1
prompt_tokens = 0
completion_tokens = 0
for op in reversed(result["data"]):
if "cost" in op:
cost = op["cost"]
prompt_tokens = op["prompt_tokens"]
completion_tokens = op["completion_tokens"]
if "operation" in op and op["operation"] == "score":
try:
score = max(op["scores"])
break
except:
continue
scores[method].append(
[result["key"], score, solved, prompt_tokens, completion_tokens, cost]
)
scores[method] = sorted(scores[method], key=lambda x: x[0])
return scores
def get_plotting_data(base_directory, score_method):
results_complete = get_complete_results(base_directory)
scores = score_method(results_complete)
results_plotting = {
method: {
"scores": [x[1] for x in scores[method]],
"solved": sum([1 for x in scores[method] if x[2]]),
"costs": [x[5] for x in scores[method]],
}
for method in scores.keys()
}
return results_plotting
def plot_results(
name,
results,
methods_order=["io", "cot", "tot", "tot2", "tog"],
methods_labels=["IO", "CoT", "ToT", "ToT2", "GoT"],
model="GPT-3.5",
length=32,
y_lower=0,
y_upper=16,
cost_upper=1.8,
display_solved=True,
annotation_offset=1,
display_left_ylabel=False,
display_right_ylabel=False,
):
methods_order = [method for method in methods_order if method in results]
# Extract scores based on the order
if name == "set_intersection":
scores_ordered = [
[min(score, length) for score in results[method]["scores"] if score != 1000]
for method in methods_order
]
elif name == "sorting":
scores_ordered = [
[
min(score, length)
for score in results[method]["scores"]
if score != 100 and score != 300
]
for method in methods_order
]
elif name == "keyword_counting":
scores_ordered = [
[
score
for score in results[method]["scores"]
if score != 100 and score != 300
]
for method in methods_order
]
elif name == "document_merging":
scores_ordered = [
[score for score in results[method]["scores"]] for method in methods_order
]
total_costs = [sum(results[method]["costs"]) for method in methods_order]
# Create figure and axis
if name == "keyword_counting" or name == "document_merging":
fig, ax = plt.subplots(dpi=150, figsize=(3.75, 5))
else:
fig, ax = plt.subplots(dpi=150, figsize=(2.5, 5))
# Create boxplots
positions = range(1, len(methods_order) + 1)
ax.boxplot(scores_ordered, positions=positions)
fig_fontsize = 12
# Set the ticks and labels
plt.yticks(fontsize=fig_fontsize)
ax.set_xticks(range(1, len(methods_order) + 1))
ax.set_xticks(range(1, len(methods_order) + 1))
if name == "keyword_counting":
ax.set_xticklabels(methods_labels, fontsize=10)
else:
ax.set_xticklabels(methods_labels, fontsize=fig_fontsize)
if name == "document_merging":
ax.set_ylim(y_lower, 12 if display_solved else 9.75)
else:
ax.set_ylim(y_lower, (y_upper + 2) if display_solved else y_upper + 1)
if name == "sorting" or name == "set_intersection":
ax1_yticks = range(
y_lower, y_upper + 1, 2 if length < 48 else (4 if length < 96 else 8)
)
ax.set_yticks(ax1_yticks)
if display_left_ylabel:
if name == "keyword_counting":
ax.set_ylabel(
f"Number of errors; the lower the better", fontsize=fig_fontsize
)
elif name == "document_merging":
ax.set_ylabel(
f"Score (out of 10); the higher the better", fontsize=fig_fontsize
)
else:
ax.set_ylabel(
f"#incorrect elements; the lower the better", fontsize=fig_fontsize
)
if name == "sorting" or name == "set_intersection":
ax.set_title(f"{length} elements")
ax2 = ax.twinx()
ax2.bar(positions, total_costs, alpha=0.5, color="blue", label="Total Cost ($)")
ax2.yaxis.set_tick_params(colors="#1919ff", labelsize=fig_fontsize)
ax2.set_ylim(0, cost_upper)
number_of_ticks = len(ax.get_yticks())
tick_interval = cost_upper / (number_of_ticks)
ax2_ticks = [tick_interval * i for i in range(number_of_ticks)]
# Set custom tick positions for ax2
ax2.set_yticks(ax2_ticks)
if display_right_ylabel:
ax2.set_ylabel(
"Total Cost ($); the lower the better",
color="#1919ff",
fontsize=fig_fontsize,
)
if display_solved:
annotation_height = y_upper + annotation_offset
count = 1
for method in methods_order:
if method not in results:
continue
solved = results[method]["solved"]
ax.text(
count,
annotation_height,
f"{solved}",
ha="center",
va="bottom",
fontsize=fig_fontsize,
)
count += 1
model = model.replace(".", "").replace("-", "").lower()
if name == "keyword_counting" or name == "document_merging":
fig.savefig(f"{name}_{model}.pdf", bbox_inches="tight")
else:
fig.savefig(f"{name}_{model}_{length}.pdf", bbox_inches="tight")
plot_results(
"set_intersection",
get_plotting_data("set_intersection_gpt35_032", get_final_scores),
methods_order=["io", "cot", "tot", "tot2", "tog2"],
length=32,
y_upper=19,
cost_upper=2,
display_solved=True,
annotation_offset=0.5,
display_left_ylabel=True,
display_right_ylabel=True,
)
plot_results(
"set_intersection",
get_plotting_data("set_intersection_gpt35_064", get_final_scores),
methods_order=["io", "cot", "tot", "tot2", "tog2"],
length=64,
y_upper=32,
cost_upper=5.4,
display_solved=True,
annotation_offset=0.2,
display_left_ylabel=True,
display_right_ylabel=True,
)
plot_results(
"set_intersection",
get_plotting_data("set_intersection_gpt35_128", get_final_scores),
methods_order=["io", "cot", "tot", "tot2", "tog2"],
length=128,
y_upper=94,
cost_upper=12,
display_solved=True,
annotation_offset=-3,
display_left_ylabel=True,
display_right_ylabel=True,
)
plot_results(
"sorting",
get_plotting_data("sorting_gpt35_032", get_final_scores),
length=32,
display_solved=False,
annotation_offset=0.5,
display_left_ylabel=True,
display_right_ylabel=True,
)
plot_results(
"sorting",
get_plotting_data("sorting_gpt35_064", get_final_scores),
length=64,
y_upper=64,
cost_upper=5.1,
display_solved=False,
display_left_ylabel=True,
display_right_ylabel=True,
)
plot_results(
"sorting",
get_plotting_data("sorting_gpt35_128", get_final_scores),
length=128,
y_upper=128,
cost_upper=17,
display_solved=False,
display_left_ylabel=True,
display_right_ylabel=True,
)
plot_results(
"keyword_counting",
get_plotting_data("keyword_counting_gpt35", get_final_scores),
methods_order=["io", "cot", "tot", "tot2", "gsp4", "gsp8", "gspx"],
methods_labels=["IO", "CoT", "ToT", "ToT2", "GoT4", "GoT8", "GoTx"],
y_upper=35,
cost_upper=9,
display_solved=True,
annotation_offset=-0.3,
display_left_ylabel=True,
display_right_ylabel=True,
)
plot_results(
"document_merging",
get_plotting_data("document_merging_gpt35_16k", get_final_scores_doc_merge),
methods_order=["io", "cot", "tot", "gsp", "gsp2"],
methods_labels=["IO", "CoT", "ToT", "GoT", "GoT2"],
y_upper=10,
cost_upper=15,
display_solved=False,
display_left_ylabel=True,
display_right_ylabel=True,
)