class Kuroko2::ExecutionLogger::CloudWatchLogs

def get_logs(token = @get_log_token)
  response = client.get_log_events({
    log_group_name: @group_name,
    log_stream_name: @stream_name,
    next_token: token,
    start_from_head: true,
  })
  @get_log_token = response.next_forward_token
  response
rescue Aws::CloudWatchLogs::Errors::ResourceNotFoundException
  raise ExecutionLogger::NotFound
end