class Kuroko2::ExecutionLogger::CloudWatchLogs

def create_log_stream
  Kuroko2.logger.info("Create log stream: #{@group_name} #{@stream_name}")
  client.create_log_stream(log_group_name: @group_name, log_stream_name: @stream_name)
rescue Aws::CloudWatchLogs::Errors::ResourceAlreadyExistsException
  warn "Log stream '#{@stream_name}' already exists"
end