def _get_cvat_statuses()

in backend/model_garden/management/commands/process_task_statuses.py [0:0]

• 6 lines of code
• 3 McCabe index (conditional complexity)

  def _get_cvat_statuses(self, labeling_tasks: List[LabelingTask]):
    with ThreadPoolExecutor() as executor:
      future_to_labeling_task = {executor.submit(self._cvat_service.get_task, t.task_id): t for t in labeling_tasks}
      for future in as_completed(future_to_labeling_task):
        labeling_task = future_to_labeling_task[future]
        yield labeling_task, future