[BugFix & Feature]

1.Fix set_max_subnet or set_min_subnet not found exception
2 Add the fleibility to define custom subnet kinds
3.Support to specifiy None with ResorceEstimator

Signed-off-by: Ming-Hsuan-Tu <qrnnis2623891@gmail.com>

Author: twmht

mmrazor/engine/runner/subnet_val_loop.py

@@ -21,8 +21,8 @@ class SubnetValLoop(ValLoop, CalibrateBNMixin):
         evaluator (Evaluator or dict or list): Used for computing metrics.
         fp16 (bool): Whether to enable fp16 validation. Defaults to
             False.
-        evaluate_fixed_subnet (bool): Whether to evaluate a fixed subnet only
-            or not. Defaults to False.
+        fix_subnet_kind (str): fix subnet kinds when evaluate, this would be
+            `sample_kinds` if not specified
         calibrate_sample_num (int): The number of images to compute the true
             average of per-batch mean/variance instead of the running average.
             Defaults to 4096.
@@ -36,7 +36,7 @@ def __init__(
         dataloader: Union[DataLoader, Dict],
         evaluator: Union[Evaluator, Dict, List],
         fp16: bool = False,
-        evaluate_fixed_subnet: bool = False,
+        fix_subnet_kinds: List[str] = [],
         calibrate_sample_num: int = 4096,
         estimator_cfg: Optional[Dict] = dict(type='mmrazor.ResourceEstimator')
     ) -> None:
@@ -48,9 +48,13 @@ def __init__(
             model = self.runner.model
 
         self.model = model
-        self.evaluate_fixed_subnet = evaluate_fixed_subnet
+        self.evaluate_kinds = fix_subnet_kinds if len(
+            fix_subnet_kinds) > 0 else getattr(self.model, 'sample_kinds')
+
         self.calibrate_sample_num = calibrate_sample_num
-        self.estimator = TASK_UTILS.build(estimator_cfg)
+        self.estimator = None
+        if estimator_cfg:
+            self.estimator = TASK_UTILS.build(estimator_cfg)
 
     def run(self):
         """Launch validation."""
@@ -59,24 +63,19 @@ def run(self):
 
         all_metrics = dict()
 
-        if self.evaluate_fixed_subnet:
+        for kind in self.evaluate_kinds:
+            if kind == 'max':
+                self.model.mutator.set_max_choices()
+            elif kind == 'min':
+                self.model.mutator.set_min_choices()
+            elif 'random' in kind:
+                self.model.mutator.set_choices(
+                    self.model.mutator.sample_choices())
+            else:
+                raise NotImplementedError(f'{kind}')
+
             metrics = self._evaluate_once()
-            all_metrics.update(add_prefix(metrics, 'fix_subnet'))
-        elif hasattr(self.model, 'sample_kinds'):
-            for kind in self.model.sample_kinds:
-                if kind == 'max':
-                    self.model.set_max_subnet()
-                    metrics = self._evaluate_once()
-                    all_metrics.update(add_prefix(metrics, 'max_subnet'))
-                elif kind == 'min':
-                    self.model.set_min_subnet()
-                    metrics = self._evaluate_once()
-                    all_metrics.update(add_prefix(metrics, 'min_subnet'))
-                elif 'random' in kind:
-                    self.model.mutator.set_choices(
-                        self.model.mutator.sample_choices())
-                    metrics = self._evaluate_once()
-                    all_metrics.update(add_prefix(metrics, f'{kind}_subnet'))
+            all_metrics.update(add_prefix(metrics, f'{kind}_subnet'))
 
         self.runner.call_hook('after_val_epoch', metrics=all_metrics)
         self.runner.call_hook('after_val')
@@ -90,7 +89,8 @@ def _evaluate_once(self) -> Dict:
             self.run_iter(idx, data_batch)
 
         metrics = self.evaluator.evaluate(len(self.dataloader.dataset))
-        resource_metrics = self.estimator.estimate(self.model)
-        metrics.update(resource_metrics)
+        if self.estimator:
+            resource_metrics = self.estimator.estimate(self.model)
+            metrics.update(resource_metrics)
 
         return metrics

tests/test_engine/test_runner/test_subnet_val_loop.py

@@ -0,0 +1,49 @@
+# Copyright (c) OpenMMLab. All rights reserved.
+from unittest.mock import MagicMock, call, patch
+
+from mmrazor.engine.runner import SubnetValLoop
+
+
+def test_subnet_val_loop():
+    runner = MagicMock()
+    runner.distributed = False
+    runner.model = MagicMock()
+    dataloader = MagicMock()
+    evaluator = [MagicMock()]
+    fix_subnet_kinds = ['max', 'min']
+    loop = SubnetValLoop(
+        runner,
+        dataloader,
+        evaluator,
+        fix_subnet_kinds=fix_subnet_kinds,
+        estimator_cfg=None)
+    runner.train_dataloader = MagicMock()
+    with patch.object(loop, '_evaluate_once') as evaluate_mock:
+        evaluate_mock.return_value = dict(acc=10)
+        all_metrics = dict()
+        all_metrics['max_subnet.acc'] = 10
+        all_metrics['min_subnet.acc'] = 10
+        loop.run()
+        loop.runner.call_hook.assert_has_calls([
+            call('before_val'),
+            call('before_val_epoch'),
+            call('after_val_epoch', metrics=all_metrics),
+            call('after_val')
+        ])
+        evaluate_mock.assert_has_calls([(call(), call())])
+
+    runner.dataloader = MagicMock()
+    runner.dataloader.dataset = MagicMock()
+    loop.dataloader.__iter__.return_value = ['data_batch1']
+    with patch.object(loop, 'calibrate_bn_statistics') as calibration_bn_mock:
+        with patch.object(loop, 'run_iter') as run_iter_mock:
+            eval_result = dict(acc=10)
+            loop.evaluator.evaluate.return_value = eval_result
+            result = loop._evaluate_once()
+            calibration_bn_mock.assert_called_with(runner.train_dataloader,
+                                                   loop.calibrate_sample_num)
+            runner.model.eval.assert_called()
+            run_iter_mock.assert_called_with(0, 'data_batch1')
+            loop.evaluator.evaluate.assert_called_with(
+                len(runner.dataloader.dataset))
+            assert result == eval_result