fetch is a class method!

examples/create_arrow_model.py

@@ -5,7 +5,7 @@
 from mttl.models.containers.selectors import ArrowSelectorConfig
 from mttl.models.expert_model import MultiExpertModel, MultiExpertModelConfig
 from mttl.models.library.expert_library import ExpertLibrary
-from mttl.models.library.library_transforms import ArrowConfig, ArrowTransform
+from mttl.models.library.library_transforms import ArrowTransform, ArrowTransformConfig
 
 
 @click.command()
@@ -30,7 +30,7 @@ def make_arrow(experts, push_to_hub):
         library.add_expert_from_ckpt(path)
 
     # compute arrow prototypes and store them in the library
-    arrow_config = ArrowConfig()
+    arrow_config = ArrowTransformConfig()
     transform = ArrowTransform(arrow_config)
     transform.transform(library, persist=True)
 

mttl/logging.py

@@ -10,7 +10,6 @@
 
 # warning if logger is not initialized
 logger = logging.getLogger("mttl")
-logger.setLevel(logging.WARNING)
 logging.getLogger("datasets.arrow_dataset").setLevel(logging.CRITICAL + 1)
 
 

mttl/models/containers/selectors/arrow_selector.py

@@ -16,9 +16,12 @@ def compute_arrow_embeddings(
     add_base_proto=False,
     recompute_prototypes=False,
 ) -> str:
-    from mttl.models.library.library_transforms import ArrowConfig, ArrowTransform
+    from mttl.models.library.library_transforms import (
+        ArrowTransform,
+        ArrowTransformConfig,
+    )
 
-    cfg = ArrowConfig(
+    cfg = ArrowTransformConfig(
         name=selector_data_id,
         ab_only=ab_only,
         tie_params=tie_params or "default",
@@ -48,8 +51,6 @@ class ArrowSelector(PerTokenSelector):
     @artifacts_cache
     def load_from_library(cls, config):
         """Fetches prototypes from the library."""
-        from mttl.models.library.library_transforms import ArrowConfig, ArrowTransform
+        from mttl.models.library.library_transforms import ArrowTransform
 
-        return ArrowTransform(ArrowConfig(name=config.selector_data_id)).fetch(
-            config.library_id
-        )
+        return ArrowTransform.fetch(config.library_id, config.selector_data_id)

mttl/models/containers/selectors/average_activation_selector.py

@@ -53,11 +53,9 @@ class AverageActivationSelector(PerTokenSelector):
     @artifacts_cache
     def load_from_library(cls, config):
         """Fetches prototypes from the library."""
-        from mttl.models.library.library_transforms import (
-            HiddenStateComputer,
-            HiddenStateComputerConfig,
-        )
+        from mttl.models.library.library_transforms import HiddenStateComputer
 
-        return HiddenStateComputer(
-            HiddenStateComputerConfig(name=config.selector_data_id)
-        ).fetch(config.library_id)
+        return HiddenStateComputer.fetch(
+            config.library_id,
+            config.selector_data_id,
+        )

mttl/models/containers/selectors/phatgoose_selector.py

@@ -28,11 +28,11 @@ def compute_phatgoose_embeddings(
 ) -> str:
     """Computes Phatgoose embeddings for the given library."""
     from mttl.models.library.library_transforms import (
-        PhatgooseConfig,
         PhatgooseTransform,
+        PhatgooseTransformConfig,
     )
 
-    cfg = PhatgooseConfig(
+    cfg = PhatgooseTransformConfig(
         n_steps=n_steps_pg,
         learning_rate=learning_rate_pg,
         name=selector_data_id,
@@ -70,14 +70,9 @@ def __init__(self, config, **kwargs) -> None:
     @artifacts_cache
     def load_from_library(cls, config):
         """Fetches prototypes from the library."""
-        from mttl.models.library.library_transforms import (
-            PhatgooseConfig,
-            PhatgooseTransform,
-        )
+        from mttl.models.library.library_transforms import PhatgooseTransform
 
-        return PhatgooseTransform(PhatgooseConfig(name=config.selector_data_id)).fetch(
-            config.library_id
-        )
+        return PhatgooseTransform.fetch(config.library_id, config.selector_data_id)
 
 
 @dataclass

mttl/models/expert_model.py

@@ -571,7 +571,7 @@ def from_pretrained_library(
             if isinstance(selector_config, LoadableSelectorConfig):
                 selector_config.library_id = repo_id
 
-            elif isinstance(selector_config, dict):
+            elif isinstance(selector_config, MultiSelectorConfig):
                 for modifier_name, cfg in selector_config.items():
                     # inject the library id if it is None
                     if (