docs: def get_current_async():
      """Return a reference to the currently executing Async job object
      or None if not in an Async job.
      """
      local_context = _local.get_local_context()
  
      if local_context._executing_async:
          return local_context._executing_async[-1]
  
      raise errors.NotInContextError('Not in an _ExecutionContext.')