Skip to content

resolver

Resolver

Resolves stage-specific configurations from the main configuration.

Source code in lighter/engine/resolver.py 
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
class Resolver:
    """
    Resolves stage-specific configurations from the main configuration.
    """

    STAGE_MODES = {
        Stage.FIT: [Mode.TRAIN, Mode.VAL],
        Stage.VALIDATE: [Mode.VAL],
        Stage.TEST: [Mode.TEST],
        Stage.PREDICT: [Mode.PREDICT],
    }

    def __init__(self, config: Config):
        self.config = config

    def get_stage_config(self, stage: str) -> Config:
        """Get stage-specific configuration by filtering unused components."""
        if stage not in self.STAGE_MODES:
            raise ValueError(f"Invalid stage: {stage}. Allowed stages are {list(self.STAGE_MODES)}")

        stage_config = self.config.get().copy()
        system_config = stage_config.get("system", {})
        dataloader_config = system_config.get("dataloaders", {})
        metrics_config = system_config.get("metrics", {})

        # Remove dataloaders not relevant to the current stage
        for mode in set(dataloader_config) - set(self.STAGE_MODES[stage]):
            dataloader_config.pop(mode, None)

        # Remove metrics not relevant to the current stage
        for mode in set(metrics_config) - set(self.STAGE_MODES[stage]):
            metrics_config.pop(mode, None)

        # Remove optimizer, scheduler, and criterion if not relevant to the current stage
        if stage in [Stage.VALIDATE, Stage.TEST, Stage.PREDICT]:
            if stage != Stage.VALIDATE:
                system_config.pop("criterion", None)
            system_config.pop("optimizer", None)
            system_config.pop("scheduler", None)

        # Retain only relevant args for the current stage
        if "args" in stage_config:
            stage_config["args"] = {stage: stage_config["args"].get(stage, {})}

        return Config(stage_config, validate=False)

get_stage_config(stage)

Get stage-specific configuration by filtering unused components.

Source code in lighter/engine/resolver.py 
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
def get_stage_config(self, stage: str) -> Config:
    """Get stage-specific configuration by filtering unused components."""
    if stage not in self.STAGE_MODES:
        raise ValueError(f"Invalid stage: {stage}. Allowed stages are {list(self.STAGE_MODES)}")

    stage_config = self.config.get().copy()
    system_config = stage_config.get("system", {})
    dataloader_config = system_config.get("dataloaders", {})
    metrics_config = system_config.get("metrics", {})

    # Remove dataloaders not relevant to the current stage
    for mode in set(dataloader_config) - set(self.STAGE_MODES[stage]):
        dataloader_config.pop(mode, None)

    # Remove metrics not relevant to the current stage
    for mode in set(metrics_config) - set(self.STAGE_MODES[stage]):
        metrics_config.pop(mode, None)

    # Remove optimizer, scheduler, and criterion if not relevant to the current stage
    if stage in [Stage.VALIDATE, Stage.TEST, Stage.PREDICT]:
        if stage != Stage.VALIDATE:
            system_config.pop("criterion", None)
        system_config.pop("optimizer", None)
        system_config.pop("scheduler", None)

    # Retain only relevant args for the current stage
    if "args" in stage_config:
        stage_config["args"] = {stage: stage_config["args"].get(stage, {})}

    return Config(stage_config, validate=False)