fix upload

Author: VaghinakDev

pytest.ini

@@ -3,4 +3,4 @@ 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/lib/core/usecases/annotations.py

@@ -120,8 +120,8 @@ def __init__(
         self._annotation_upload_data = None
         self._item_ids = []
         self._s3_bucket = None
-        self._big_files_queue = asyncio.Queue()
-        self._small_files_queue = asyncio.Queue()
+        self._big_files_queue = None
+        self._small_files_queue = None
         self._report = Report([], [], [], [])
 
     @staticmethod
@@ -334,7 +334,6 @@ async def upload(_chunk):
                 self._report.missing_attrs.extend(report.missing_attrs)
             except Exception:
                 import traceback
-
                 traceback.print_exc()
                 self._report.failed_annotations.extend([i.name for i in chunk])
 
@@ -408,6 +407,8 @@ async def distribute_queues(self, items_to_upload: list):
                         else:
                             self._small_files_queue.put_nowait(t_item)
                     except (ValidationError, AppException):
+                        data[idx][1] = True
+                        self.reporter.update_progress()
                         self._report.failed_annotations.append(item.name)
                     finally:
                         data[idx][1] = True
@@ -417,6 +418,8 @@ async def distribute_queues(self, items_to_upload: list):
 
     async def run_workers(self, items_to_upload):
         try:
+            self._big_files_queue = asyncio.Queue()
+            self._small_files_queue = asyncio.Queue()
             await asyncio.gather(
                 self.distribute_queues(items_to_upload),
                 self.upload_small_annotations(),