utilizing defaultdict, optimize single_selection check

openvinotoolkit · Oct 18, 2022 · 022f72a · 022f72a
1 parent 192820f
commit 022f72a
Show file tree

Hide file tree

Showing 2 changed files with 26 additions and 15 deletions.
diff --git a/datumaro/plugins/datumaro_format/converter.py b/datumaro/plugins/datumaro_format/converter.py
@@ -7,6 +7,7 @@
 import os
 import os.path as osp
 import shutil
+from collections import defaultdict
 
 import numpy as np
 import pycocotools.mask as mask_utils
@@ -336,9 +337,13 @@ def apply(self):
         for writer in writers.values():
             writer.add_categories(self._extractor.categories())
 
+        single_selection_info = self._extruct_single_selection_info(self._extractor.categories())
+
         for item in self._extractor:
             subset = item.subset or DEFAULT_SUBSET_NAME
-            item = self._filterout_for_single_selection(item, self._extractor.categories())
+            item = self._filterout_for_single_selection(
+                item, self._extractor.categories(), single_selection_info
+            )
             writers[subset].add_item(item)
 
         for subset, writer in writers.items():
@@ -388,19 +393,23 @@ def patch(cls, dataset, patch, save_dir, **kwargs):
                 shutil.rmtree(related_images_path)
 
     @staticmethod
-    def _filterout_for_single_selection(item, categories):
-        if AnnotationType.label not in categories:
-            return item
-
+    def _extruct_single_selection_info(categories):
         name2parent_ss = {}
         for label_category in categories[AnnotationType.label]:
             name2parent_ss[label_category.name] = (
                 label_category.parent,
                 label_category.single_selection,
             )
 
+        return name2parent_ss
+
+    @staticmethod
+    def _filterout_for_single_selection(item, categories, name2parent_ss):
+        if AnnotationType.label not in categories:
+            return item
+
         # collect childrens that have the same parent which only allow single-selection
-        parent2ss_indices = {}
+        parent2ss_indices = defaultdict(list)
         for i, annotation in enumerate(item.annotations):
             if annotation._type != AnnotationType.label:
                 continue
@@ -414,7 +423,7 @@ def _filterout_for_single_selection(item, categories):
             _, single_selection = name2parent_ss[parent]
 
             if single_selection:
-                parent2ss_indices[parent] = parent2ss_indices.get(parent, []) + [i]
+                parent2ss_indices[parent] += [i]
 
         # remove labels that dis-obey the single-selection rule
         for indices in parent2ss_indices.values():

diff --git a/tests/test_labeling.py b/tests/test_labeling.py
@@ -2,6 +2,7 @@
 #
 # SPDX-License-Identifier: MIT
 import os.path as osp
+import tempfile
 from unittest.case import TestCase
 
 import numpy as np
@@ -13,8 +14,6 @@
 
 from .requirements import Requirements, mark_requirement
 
-TMP_DATASET_DIR = osp.join(osp.dirname(__file__), "tmp", "test_labeling")
-
 
 class LabelingTest(TestCase):
     @mark_requirement(Requirements.DATUM_GENERAL_REQ)
@@ -79,8 +78,9 @@ def test_label_single_selection_filtered(self):
             },
         )
 
-        dataset.export(TMP_DATASET_DIR, format="datumaro")
-        dataset_imported = Dataset.import_from(TMP_DATASET_DIR, format="datumaro")
+        with tempfile.TemporaryDirectory() as temp_home:
+            dataset.export(temp_home, format="datumaro")
+            dataset_imported = Dataset.import_from(temp_home, format="datumaro")
 
         for item in dataset_imported:
             self.assertEqual(len(item.annotations), 0)
@@ -115,8 +115,9 @@ def test_label_single_selection_not_filtered(self):
             },
         )
 
-        dataset.export(TMP_DATASET_DIR, format="datumaro")
-        dataset_imported = Dataset.import_from(TMP_DATASET_DIR, format="datumaro")
+        with tempfile.TemporaryDirectory() as temp_home:
+            dataset.export(temp_home, format="datumaro")
+            dataset_imported = Dataset.import_from(temp_home, format="datumaro")
 
         for item in dataset_imported:
             self.assertEqual(len(item.annotations), 2)
@@ -147,8 +148,9 @@ def test_label_single_selection_correct(self):
             },
         )
 
-        dataset.export(TMP_DATASET_DIR, format="datumaro")
-        dataset_imported = Dataset.import_from(TMP_DATASET_DIR, format="datumaro")
+        with tempfile.TemporaryDirectory() as temp_home:
+            dataset.export(temp_home, format="datumaro")
+            dataset_imported = Dataset.import_from(temp_home, format="datumaro")
 
         for item in dataset_imported:
             self.assertEqual(len(item.annotations), 1)