docs: def process_async_task(headers, request_body):
      """Process an Async task and execute the requested function."""
      async_options = json.loads(request_body)
      async = async_from_options(async_options)
  
      _log_task_info(headers,
                     extra_task_info=async.get_options().get('_extra_task_info'))
  
      logging.info(async._function_path)
  
      with context.execution_context_from_async(async):
          run_job()
  
      return 200, async._function_path