class ActiveRecord::AsynchronousQueriesTracker

def current_session
  @stack.last or raise ActiveRecordError, "Can't perform asynchronous queries without a query session"
end