"src/lib/i18n/locales/es-ES/translation.json" did not exist on "12c74b2cd1d9e28f76e676779e84e33ac755cc46"
__init__.py 5.3 KB
Newer Older
1
import os
lintangsutawika's avatar
lintangsutawika committed
2
from typing import List, Union
&'s avatar
& committed
3

4
5
from .gsm8k import *
from .triviaqa import *
lintangsutawika's avatar
lintangsutawika committed
6

7
from lm_eval import utils
lintangsutawika's avatar
lintangsutawika committed
8
from lm_eval.logger import eval_logger
9
from lm_eval.api.task import TaskConfig, Task, ConfigurableTask
lintangsutawika's avatar
lintangsutawika committed
10
from lm_eval.api.registry import (
11
12
    register_task,
    register_group,
lintangsutawika's avatar
lintangsutawika committed
13
14
    TASK_REGISTRY,
    GROUP_REGISTRY,
lintangsutawika's avatar
lintangsutawika committed
15
)
lintangsutawika's avatar
lintangsutawika committed
16

17

18
ALL_TASKS = sorted(list(TASK_REGISTRY.keys()) + list(GROUP_REGISTRY.keys()))
&'s avatar
& committed
19
20


21
def get_task_name_from_config(task_config):
22
    return "{dataset_path}_{dataset_name}".format(**task_config)
23
24


25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
def include_task_folder(task_dir):
    """
    Calling this function
    """
    for root, subdirs, file_list in os.walk(task_dir):
        if (subdirs == []) and (len(file_list) > 0):
            for f in file_list:
                if f.endswith(".yaml"):
                    yaml_path = os.path.join(root, f)
                    try:
                        config = utils.load_yaml_config(yaml_path)

                        SubClass = type(
                            config["task"] + "ConfigurableTask",
                            (ConfigurableTask,),
                            {"CONFIG": TaskConfig(**config)},
                        )
42

43
44
45
                        if "task" in config:
                            task_name = "{}".format(config["task"])
                            register_task(task_name)(SubClass)
46

47
48
49
50
51
52
53
54
55
56
                        if "group" in config:
                            for group in config["group"]:
                                register_group(group)(SubClass)
                    except Exception as error:
                        eval_logger.warning(
                            "Failed to load config in\n"
                            f"                                 {yaml_path}\n"
                            "                                 Config will not be added to registry\n"
                            f"                                 Error: {error}"
                        )
57

58

59
60
task_dir = os.path.dirname(os.path.abspath(__file__)) + "/"
include_task_folder(task_dir)
lintangsutawika's avatar
lintangsutawika committed
61

lintangsutawika's avatar
lintangsutawika committed
62

63
64
def get_task(task_name, config):
    try:
65
        return TASK_REGISTRY[task_name](config=config)
66
    except KeyError:
lintangsutawika's avatar
lintangsutawika committed
67
        eval_logger.info("Available tasks:")
lintangsutawika's avatar
update  
lintangsutawika committed
68
        eval_logger.info(ALL_TASKS)
lintangsutawika's avatar
lintangsutawika committed
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
        raise KeyError(f"Missing task {task_name}")


def get_task_name_from_object(task_object):
    for name, class_ in TASK_REGISTRY.items():
        if class_ is task_object:
            return name

    # TODO: scrap this
    # this gives a mechanism for non-registered tasks to have a custom name anyways when reporting
    return (
        task_object.EVAL_HARNESS_NAME
        if hasattr(task_object, "EVAL_HARNESS_NAME")
        else type(task_object).__name__
    )


# TODO: pass num_fewshot and other cmdline overrides in a better way
lintangsutawika's avatar
lintangsutawika committed
87
88
89
def get_task_dict(task_name_list: List[Union[str, dict, Task]], **kwargs):

    config = {**kwargs}
90
91
92
93
94
95
96
97
98
99
100
101
102

    task_name_from_registry_dict = {}
    task_name_from_config_dict = {}
    task_name_from_object_dict = {}

    for task_element in task_name_list:
        if isinstance(task_element, str):

            if task_element in GROUP_REGISTRY:
                for task_name in GROUP_REGISTRY[task_element]:
                    if task_name not in task_name_from_registry_dict:
                        task_name_from_registry_dict = {
                            **task_name_from_registry_dict,
lintangsutawika's avatar
lintangsutawika committed
103
104
                            task_name: get_task(task_name=task_name, config=config),
                        }
105
            else:
106
                task_name = task_element
107
108
109
                if task_name not in task_name_from_registry_dict:
                    task_name_from_registry_dict = {
                        **task_name_from_registry_dict,
lintangsutawika's avatar
lintangsutawika committed
110
111
                        task_name: get_task(task_name=task_element, config=config),
                    }
112
113

        elif isinstance(task_element, dict):
114
            task_element.update(config)
115
116
117
            task_name_from_config_dict = {
                **task_name_from_config_dict,
                get_task_name_from_config(task_element): ConfigurableTask(
118
                    config=task_element
lintangsutawika's avatar
lintangsutawika committed
119
                ),
120
121
122
123
124
125
            }

        elif isinstance(task_element, Task):

            task_name_from_object_dict = {
                **task_name_from_object_dict,
lintangsutawika's avatar
lintangsutawika committed
126
                get_task_name_from_object(task_element): task_element,
127
            }
lintangsutawika's avatar
lintangsutawika committed
128

129
130
131
132
133
    # task_name_from_registry_dict = {
    #     task_name: get_task(
    #         task_name=task_name,
    #         task_config=config
    #     )
lintangsutawika's avatar
lintangsutawika committed
134
    #     for group_name in task_name_list for task_name in GROUP_REGISTRY[group_name]
135
136
137
138
139
140
141
142
143
144
    #     if (isinstance(group_name, str)) and (group_name in GROUP_REGISTRY)
    # }
    # task_name_from_config_dict = {
    #     get_task_name_from_config(task_config): ConfigurableTask(
    #         config=task_config
    #     )
    #     for task_config in task_name_list
    #     if isinstance(task_config, dict)
    # }
    # # TODO: Do we still need this?
lintangsutawika's avatar
lintangsutawika committed
145
146
147
148
149
    # task_name_from_object_dict = {
    #     get_task_name_from_object(task_object): task_object
    #     for task_object in task_name_list
    #     if isinstance(task_object, Task)
    # }
150

lintangsutawika's avatar
lintangsutawika committed
151
152
153
    assert set(task_name_from_registry_dict.keys()).isdisjoint(
        set(task_name_from_object_dict.keys())
    )
lintangsutawika's avatar
lintangsutawika committed
154
155
156
    return {
        **task_name_from_registry_dict,
        **task_name_from_config_dict,
157
        **task_name_from_object_dict,
lintangsutawika's avatar
lintangsutawika committed
158
    }