class_docstr: Managing class for the acute evaluator process.
  
  Relevant args are parsed in the `setup_args` function above.
class_docstr_tok: ["Managing","class","for","the","acute","evaluator","process",".","Relevant","args","are","parsed","in","the","`","setup_args","`","function","above","."]
docstr: Return task to task_queue.
  
  If the task is an onboarding task, indicate that the worker has
  another onboarding task to do.
  
  :param worker_id:
      worker id of worker who is returning task
  
  :param task_data:
      list of unfinished tasks to return to the queue.
docstr_tok: ["Return","task","to","task_queue",".","If","the","task","is","an","onboarding","task",",","indicate","that","the","worker","has","another","onboarding","task","to","do",".",":","param","worker_id",":","worker","id","of","worker","who","is","returning","task",":","param","task_data",":","list","of","unfinished","tasks","to","return","to","the","queue","."]
code: def requeue_task_data(
      self, worker_id: str, task_data: List[PairingsDict]
  ):
      """
      Return task to task_queue.
  
      If the task is an onboarding task, indicate that the worker has
      another onboarding task to do.
  
      :param worker_id:
          worker id of worker who is returning task
  
      :param task_data:
          list of unfinished tasks to return to the queue.
      """
      worker_data = self._get_worker_data(worker_id)
      for subtask_data in task_data:
          if subtask_data["task_specs"].get("is_onboarding", False):
              worker_data["onboarding_todo"].append(
                  subtask_data["pair_id"]
              )
          else:
              self.task_queue.put(subtask_data)
              try:
                  worker_data["tasks_completed"].remove(
                      subtask_data["pair_id"]
                  )
                  for d_id in self._get_dialogue_ids(subtask_data):
                      worker_data["conversations_seen"].remove(d_id)
              except ValueError:
                  # Task may have shown up in worker's task queue twice
                  # due to some unfortunate race condition
                  logger.exception(
                      f"could not remove task from worker {worker_id} history",
                      exc_info=True,
                  )
  
imports: import json
  import queue
  import random
  from typing import List, Any, Dict, Tuple, Set, TYPE_CHECKING
  from mephisto.utils.logger_core import get_logger
  from mephisto.abstractions.blueprint import SharedTaskState, TaskRunner
  from omegaconf import DictConfig
label_desc: Use image node_id 10 for calling the AcuteEvalRunner obj's underlying member method code with example usage: obj.requeue_task_data(worker_id, task_data) without return types