code: def check_complete(task, out_queue):
      
      logger.debug("Checking if %s is complete", task)
      try:
          is_complete = task.complete()
      except Exception:
          is_complete = TracebackWrapper(traceback.format_exc())
      out_queue.put((task, is_complete))
docs: Checks if task is complete, puts the result to out_queue.