def _upload_annotations()

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

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

  def _upload_annotations(self, labeling_tasks: List[LabelingTask]):
    logger.info(f"Uploading annotations for {len(labeling_tasks)} labeling tasks")
    with ThreadPoolExecutor() as executor:
      future_to_labeling_task = {executor.submit(self._upload_labeling_task_annotations, t): 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