Version update

Author: VaghinakDev

pytest.ini

@@ -3,5 +3,5 @@ minversion = 3.7
 log_cli=true
 python_files = test_*.py
 ;pytest_plugins = ['pytest_profiling']
-addopts = -n auto --dist=loadscope
+;addopts = -n auto --dist=loadscope
 

src/superannotate/__init__.py

@@ -3,7 +3,7 @@
 import sys
 import typing
 
-__version__ = "4.4.10dev7"
+__version__ = "4.4.10dev8"
 
 sys.path.append(os.path.split(os.path.realpath(__file__))[0])
 

src/superannotate/lib/core/usecases/annotations.py

@@ -1486,12 +1486,12 @@ async def run_workers(
             )
         if small_annotations:
             self._small_annotations_queue = asyncio.Queue()
-        small_chunks = divide_to_chunks(
-            small_annotations, size=self._config.ANNOTATION_CHUNK_SIZE
-        )
-        for chunk in small_chunks:
-            self._small_annotations_queue.put_nowait(chunk)
-        self._small_annotations_queue.put_nowait(None)
+            small_chunks = divide_to_chunks(
+                small_annotations, size=self._config.ANNOTATION_CHUNK_SIZE
+            )
+            for chunk in small_chunks:
+                self._small_annotations_queue.put_nowait(chunk)
+            self._small_annotations_queue.put_nowait(None)
 
         annotations.extend(
             list(
@@ -1520,11 +1520,13 @@ def execute(self):
                     self.reporter.log_warning(
                         f"Could not find annotations for {len_provided_items - len_items}/{len_provided_items} items."
                     )
-            else:
+            elif self._item_names is None:
                 condition = Condition("project_id", self._project.id, EQ) & Condition(
                     "folder_id", self._folder.id, EQ
                 )
                 items = get_or_raise(self._service_provider.items.list(condition))
+            else:
+                items = []
             id_item_map = {i.id: i for i in items}
             if not items:
                 logger.info("No annotations to download.")

src/superannotate/lib/core/usecases/projects.py

@@ -704,8 +704,8 @@ def execute(self):
             team_users = set()
             project_users = {user.user_id for user in self._project.users}
             for user in self._team.users:
-                if user["user_role"] > constances.UserRole.ADMIN.value:
-                    team_users.add(user["email"])
+                if user.user_role > constances.UserRole.ADMIN.value:
+                    team_users.add(user.email)
             # collecting pending team users which is not admin
             for user in self._team.pending_invitations:
                 if user["user_role"] > constances.UserRole.ADMIN.value:
@@ -772,7 +772,7 @@ def __init__(
 
     def execute(self):
         if self.is_valid():
-            team_users = {user["email"] for user in self._team.users}
+            team_users = {user.email for user in self._team.users}
             # collecting pending team users
             team_users.update(
                 {user["email"] for user in self._team.pending_invitations}

src/superannotate/lib/infrastructure/services/annotation.py

@@ -301,6 +301,7 @@ async def upload_small_annotations(
             response = UploadAnnotationsResponse()
             response.status = _response.status
             response._content = await _response.text()
+            #  TODO add error handling
             response.data = parse_obj_as(UploadAnnotations, data_json)
             return response
 

tests/integration/annotations/test_get_annotations.py

@@ -130,7 +130,7 @@ def test_get_annotations_logs(self):
         items_names = [self.IMAGE_NAME] * 4
         items_names.append("Non-existent item")
         with self.assertLogs("sa", level="INFO") as cm:
-            assert len(sa.get_annotations(self.PROJECT_NAME, items_names)) == 4
+            assert len(sa.get_annotations(self.PROJECT_NAME, items_names)) == 1
             assert (
                 "INFO:sa:Dropping duplicates. Found 2/5 unique items." == cm.output[0]
             )
@@ -206,5 +206,3 @@ def test_empty_list_get(self):
         )
         annotations = sa.get_annotations(self.PROJECT_NAME, items=[])
         assert len(annotations) == 0
-        annotations = sa.get_annotations(self.PROJECT_NAME, items=None)
-        assert len(annotations) == 2

tests/integration/annotations/video/test_get_annotations_per_frame.py

@@ -62,4 +62,4 @@ def test_video_annotation_upload(self):
                 "INFO:sa:Getting annotations for 31 frames from video.mp4."
                 == cm.output[0]
             )
-            assert cm.output[0] == 1
+            assert len(cm.output) == 1