[Update] Update Summarizer for Compassbench

opencompass/summarizers/subjective/compassbench.py

@@ -1,59 +1,40 @@
 # flake8: noqa
 # yapf: disable
-import copy
+import csv
 import os
 import os.path as osp
 import re
 from collections import defaultdict
 from datetime import datetime
 from itertools import product
 
+import numpy as np
 import pandas as pd
 from mmengine import ConfigDict
 from tabulate import tabulate
 
 from opencompass.partitioners.sub_naive import remove_duplicate_pairs
 from opencompass.utils import dataset_abbr_from_cfg, model_abbr_from_cfg
+from opencompass.summarizers.subjective.compass_arena import (check_position_bias,
+                            model_abbr_from_cfg_used_in_summarizer)
+from opencompass.summarizers.subjective.utils import get_judgeanswer_and_reference, get_outdir
 
-from .utils import get_judgeanswer_and_reference, get_outdir
 
-
-def model_abbr_from_cfg_used_in_summarizer(model):
-    if model.get('summarizer_abbr', None):
-        return model['summarizer_abbr']
-    else:
-        return model_abbr_from_cfg(model)
-
-def post_process_compass_arena(s):
-    if result := re.findall(r'(?:选择：|Choice: )\[\[([ABC])\]\]', s):
-        return result[0]
+def post_process_wildbench_pair(judgement: str):
+    pattern = r'\"choice\": \"(.*?)\"'
+    matched_result = re.findall(pattern, judgement)
+    if matched_result:
+        return matched_result[0]
     else:
         return None
 
+MAP = {'language':['总分','中文总分','英文总分','自然语言处理_cn','创作_cn','对话_cn','NLP_en','creation_en','chat_en'],
+       'instruct':['总分','中文总分','英文总分',],
+    'reasoning':['总分','中文总分','英文总分','Common Sense Reasoning_cn','Social Reasoning_cn','Humanities (History, Finance, etc.) Professional Reasoning_cn', 'Science and Engineering Professional Reasoning_cn',
+                 'Common Sense Reasoning_en','Social Reasoning_en','Humanities (History, Finance, etc.) Professional Reasoning_en', 'Science and Engineering Professional Reasoning_en',],
+       'coding':['总分','中文总分','英文总分',]}
 
-def check_position_bias(judged_answers, references, banned_choice=['C']):
-    """Check position bias for judgellm's judgement.
-
-    Args:
-        judged_answers: The successfully extracted judgement.
-        references: The references contains original question, which is used to located the same question for different position judgement.
-    """
-    position_bias_flag = 0
-    position_bias_dict = {}
-    for judge, ref in zip(judged_answers, references):
-        question = ref['question']
-        question_hash = hash(question)
-        if question_hash not in position_bias_dict:
-            position_bias_dict[question_hash] = {
-                'question': question,
-                'judge': judge
-            }
-        else:
-            first_judge = position_bias_dict[question_hash]['judge']
-            if judge == first_judge and first_judge not in banned_choice and judge not in banned_choice:
-                # If second choice is same with first choice, there has position bias.
-                position_bias_flag += 1
-    return position_bias_flag
+MAP = {'instruct':['总分','中文总分','英文总分',]}
 
 
 class CompassBenchSummarizer:
@@ -64,23 +45,16 @@ class CompassBenchSummarizer:
             It's expected to be filled out at runtime.
     """
 
-    def __init__(self,
-                 config: ConfigDict,
-                 judge_type='general',
-                 check_pos_bias=True,
-                 summary_type='single') -> None:
+    def __init__(self, config: ConfigDict, check_pos_bias=False) -> None:
         self.tasks = []
         self.cfg = config
         self.base_models = self.cfg['datasets'][0]['base_models']
         self.compare_models = self.cfg['eval']['partitioner']['models']
         self.judge_models = self.cfg.get('judge_models', None)
         self.meta_judge_model = self.cfg.eval.partitioner.get('meta_judge_model', None)
-        self.judge_type = judge_type
-        assert self.judge_type in ['general']
-        self.judge_map = {'general': post_process_compass_arena}
-        self.judge_function = self.judge_map[self.judge_type]
+        self.judge_abbr = model_abbr_from_cfg(self.cfg['judge_models'][0])
+        self.judge_function = post_process_wildbench_pair
         self.check_pos_bias = check_pos_bias
-        self.summary_type = summary_type
 
     def get_score(self, time_str):
         output_dir, results_folder = get_outdir(self.cfg, time_str)
@@ -91,88 +65,53 @@ def get_score(self, time_str):
             self.judge_models.append(self.meta_judge_model)
 
         scores = {}
-
         for idx, judge_model_cfg in enumerate(self.judge_models):
             judge_model = model_abbr_from_cfg(judge_model_cfg)
+            scores[judge_model] = {}
             for dataset in self.cfg['datasets']:
                 dataset_abbr = dataset_abbr_from_cfg(dataset)
+                dataset_root, dataset_detail = dataset_abbr.split('/')[0], dataset_abbr.split('/')[1]
+                scores[judge_model][dataset_abbr] = {}
                 for model_pair in unique_combinations:
-                    model1 = model_pair[0]['abbr']
-                    model2 = model_pair[1]['abbr']
+                    base_model = model_pair[0]['abbr']
+                    compare_model = model_pair[1]['abbr']
                     if idx == len(self.judge_models):
-                        subdir = model1 + '_' + model2 + '_summarized-by--' + judge_model
+                        subdir = base_model + '_' + compare_model + '_summarized-by--' + judge_model
                     else:
-                        subdir = model1 + '_' + model2 + '_judged-by--' + judge_model
+                        subdir = base_model + '_' + compare_model + '_judged-by--' + judge_model
                     subdir_path = os.path.join(results_folder, subdir)
                     if not os.path.isdir(subdir_path):
                         print(subdir_path + ' is not exist! please check!')
+                        scores[judge_model][dataset_abbr][compare_model] = None
                         continue
+
                     judged_answers, references = get_judgeanswer_and_reference(dataset, subdir_path, self.judge_function)
-                    if len(judged_answers) == 0:
-                        scores[judge_model][dataset_abbr][model2] = {}
-                        continue
-                    if self.check_pos_bias:
-                        bias_num = check_position_bias(judged_answers, references)
-                    else:
-                        bias_num = 0
-                    win_model1 = defaultdict(float)
-                    win_model2 = defaultdict(float)
-                    categories = defaultdict(float)
-                    difficulties = defaultdict(float)
-                    languages = defaultdict(float)
-                    model1 = references[0]['answer1']
-                    model2 = references[0]['answer2']
-                    for prediction, reference in zip(judged_answers, references):
-                        categories[dataset_abbr] += 1
-                        categories[reference['category']] += 1
-                        difficulties['Level-' + str(reference['level'])] += 1
-                        languages['Lan-' + reference['lan']] += 1
-
-                        if prediction == 'A':
-                            if reference['answer1'] == model1:
-                                score_1, score_2 = 1, 0
-                            else:
-                                score_1, score_2 = 0, 1
-                        elif prediction == 'B':
-                            if reference['answer1'] == model1:
-                                score_1, score_2 = 0, 1
-                            else:
-                                score_1, score_2 = 1, 0
-                        elif prediction == 'C':
-                            if self.summary_type == 'half_add':
-                                score_1, score_2 = 0.5, 0.5
-                            else:
-                                score_1, score_2 = 0, 0
-
-                        win_model1[reference['category']] += score_1
-                        win_model1[dataset_abbr] += score_1
-                        win_model1['Level-' + str(reference['level'])] += score_1
-                        win_model1['Lan-' + reference['lan']] += score_1
-                        win_model2[reference['category']] += score_2
-                        win_model2[dataset_abbr] += score_2
-                        win_model2['Level-' + str(reference['level'])] += score_2
-                        win_model2['Lan-' + reference['lan']] += score_2
-                    for category in categories:
-                        win_model1[category] = win_model1[category] / categories[category] * 100
-                        win_model1[category] = round(win_model1[category], 2)
-                        win_model2[category] = win_model2[category] / categories[category] * 100
-                        win_model2[category] = round(win_model2[category], 2)
-                    win_model1['position_bias'] = bias_num
-                    win_model2['position_bias'] = bias_num
-                    for difficulty in difficulties:
-                        win_model1[difficulty] = win_model1[difficulty] / difficulties[difficulty] * 100
-                        win_model2[difficulty] = win_model2[difficulty] / difficulties[difficulty] * 100
-                    for language in languages:
-                        win_model1[language] = win_model1[language] / languages[language] * 100
-                        win_model2[language] = win_model2[language] / languages[language] * 100
-
-                    if judge_model not in scores:
-                        scores[judge_model] = {}
-                    if dataset_abbr not in scores[judge_model]:
-                        scores[judge_model][dataset_abbr] = {}
-                    scores[judge_model][dataset_abbr][model2] = win_model2
-
-        return scores, difficulties, languages
+                    win_base_model = defaultdict(float)
+                    win_compare_model = defaultdict(float)
+                    score_mapping = {'A++': 1, 'A+': 0.5, 'A=B': 0, 'B+': -0.5, 'B++': -1}
+                    cnt = defaultdict(float)
+
+                    for judged_answer, reference in zip(judged_answers, references):
+                        if judged_answer not in score_mapping:
+                            continue
+                        else:
+                            flag = 1 if reference['answer1'] == base_model else -1
+                            score_1 = score_mapping[judged_answer]*flag
+                            score_2 = -score_1
+
+                            cnt[dataset_abbr] += 1
+                            win_compare_model[dataset_abbr] += score_2
+                            win_base_model[dataset_abbr] += score_1
+
+                    for key, value in cnt.items():
+                        win_base_model[key] = win_base_model[key] / value * 100
+                        win_base_model[key] = round(win_base_model[key], 2)
+                        win_compare_model[key] = win_compare_model[key] / value * 100
+                        win_compare_model[key ] = round(win_compare_model[key], 2)
+
+                    scores[judge_model][dataset_abbr][compare_model] = win_compare_model
+
+        return scores
 
     def summarize(
             self,
@@ -186,63 +125,63 @@ def summarize(
         Returns:
             pd.DataFrame: The summary results.
         """
+        scores = self.get_score(time_str)
+        output_dir, results_folder = get_outdir(self.cfg, time_str)
+        for judge_abbr, judge_scores in scores.items():
+            new_score = {}
+            for dataset_name, model_scores in judge_scores.items():
+                dataset_root, dataset_detail = dataset_name.split('/')[0], dataset_name.split('/')[1]
+                if dataset_root not in new_score:
+                    new_score[dataset_root] = {}
+                if '_en_' in dataset_detail:
+                    for model_name, cate_score in model_scores.items():
+                        if model_name not in new_score[dataset_root]:
+                            new_score[dataset_root][model_name] = {}
+                        if len(cate_score) == 0:
+                            new_score[dataset_root][model_name]['英文总分'] = None
+                        else:
+                            new_score[dataset_root][model_name].update(cate_score)
+                            new_score[dataset_root][model_name]['英文总分'] = sum(cate_score.values()) / len(cate_score)
+                elif '_cn_' in dataset_detail or '_zh_' in dataset_detail:
+                    for model_name, cate_score in model_scores.items():
+                        if model_name not in new_score[dataset_root]:
+                            new_score[dataset_root][model_name] = {}
+                        if len(cate_score) == 0:
+                            new_score[dataset_root][model_name]['中文总分'] = None
+                        else:
+                            new_score[dataset_root][model_name].update(cate_score)
+                            new_score[dataset_root][model_name]['中文总分'] = sum(cate_score.values()) / len(cate_score)
+            for dataset, models in new_score.items():
+                for model, details in models.items():
+                    if details['英文总分'] is not None and details['中文总分'] is not None:
+                        average_score = (details['英文总分'] + details['中文总分']) / 2
+                    else:
+                        average_score = None
+                    details['总分'] = average_score
 
 
-        scores, difficulties, languages = self.get_score(time_str)
-        # scores['win_' + model1] = win_model1
-        output_dir, results_folder = get_outdir(self.cfg, time_str)
-        all_judge_file_list = []
-        all_scores = {}
-        for idx, judge_model in enumerate(self.judge_models):
-            score_by_judgemodel = {}
-            judge_abbr = model_abbr_from_cfg(judge_model)
-            for dataset in self.cfg['datasets']:
-                dataset_abbr = dataset_abbr_from_cfg(dataset)
-                summarizer_model_abbrs = [model_abbr_from_cfg_used_in_summarizer(i) for i in self.compare_models]
-                one_column = list(scores[judge_abbr][dataset_abbr].values())[0]
-                detail_headers = [i for i in one_column.keys() if i not in [dataset_abbr, 'position_bias'] and i not in difficulties and i not in languages]
-                row_headers = [dataset_abbr, 'position_bias']
-                for difficulty in difficulties:
-                    row_headers += [difficulty]
-                for language in languages:
-                    row_headers += [language]
-                row_headers += detail_headers
-                headers = [''] + summarizer_model_abbrs
-                table = []
-                for row_header in row_headers:
-                    row = [row_header]
-                    for model_cfg in self.compare_models:
-                        model_abbr = model_abbr_from_cfg(model_cfg)
-                        s = scores[judge_abbr][dataset_abbr][model_abbr].get(row_header, '')
-                        if isinstance(s, float):
-                            s = f'{s:.2f}'
-                        if isinstance(s, int):
-                            s = str(s)
-                        row.append(s)
-                    table.append(row)
-                txt = tabulate(table, headers=headers)
-                # print(txt)
-
-                if idx == len(self.judge_models):
-                    output_filename = osp.join(output_dir, dataset_abbr + '-summarized-by--' + judge_abbr + '-report.csv')
-                else:
-                    output_filename = osp.join(output_dir, dataset_abbr + '-judged-by--' + judge_abbr + '-report.csv')
-
-                with open(output_filename, 'w') as f:
-                    f.write(','.join(headers) + '\n')
-                    for line in table:
-                        f.write(','.join(line) + '\n')
-                all_judge_file_list.append(output_filename)
-            for idx, model in enumerate(summarizer_model_abbrs):
-                score_by_judgemodel[model] = {'overall': table[0][idx+1]}
-            all_scores[judge_abbr]=score_by_judgemodel
-        dfs = [pd.read_csv(file) for file in all_judge_file_list]
-
-        if len(dfs) > 1:
-            average_df = copy.deepcopy(dfs[0])
-            for col in dfs[0].columns[1:]:
-                for i in range(0, len(dfs[0])):
-                    average_df[col][i] = round(sum(df[col][i] for df in dfs) / len(dfs), 2)
-            average_csv_path = osp.join(output_dir,  'CompassBench-Averaged-' + dataset_abbr + '-report.csv')
-            average_df.to_csv(average_csv_path, index=False)
-        return {'CompassBench': all_scores}
+            df = pd.DataFrame()
+            # Iterate over the MAP and new_score to populate the DataFrame
+            for category, headers in MAP.items():
+                category_data = []
+                for model, scores in new_score[category].items():
+                    row_data = [model]
+                    for header in headers:
+                        # Append the score if available, otherwise append None
+                        row_data.append(scores.get(header, None))
+                    category_data.append(row_data)
+
+                # Create a DataFrame for the category and concatenate with the main DataFrame
+                new_headers = [category+'_'+item for item in headers]
+                category_df = pd.DataFrame(category_data, columns=[category] + new_headers)
+                df = pd.concat([df, category_df.set_index(category)], axis=1)
+
+                df_transposed = df.T
+
+
+            output_filename = osp.join(output_dir, 'summarized-by--' + judge_abbr + '-'  + '-report.csv')
+
+
+            transposed_csv_file_path = output_filename
+            df_transposed.to_csv(transposed_csv_file_path)
+            print(f'save to {output_filename}')