docs: def _completion_checker(async_id, context_id):
      """Check if all Async jobs within a Context have been run."""
  
      if not context_id:
          logging.debug("Context for async %s does not exist", async_id)
          return
  
      context = FuriousContext.from_id(context_id)
      marker = FuriousCompletionMarker.get_by_id(context_id)
  
      if marker and marker.complete:
          logging.info("Context %s already complete" % context_id)
          return True
  
      task_ids = context.task_ids
      if async_id in task_ids:
          task_ids.remove(async_id)
  
      logging.debug("Loaded context.")
      logging.debug(task_ids)
  
      done, has_errors = _check_markers(task_ids)
  
      if not done:
          return False
  
      _mark_context_complete(marker, context, has_errors)
  
      return True