lib/fluent/plugin/in_cloudwatch_logs.rb in fluent-plugin-cloudwatch-logs-0.9.1 vs lib/fluent/plugin/in_cloudwatch_logs.rb in fluent-plugin-cloudwatch-logs-0.9.2
- old
+ new
@@ -188,10 +188,10 @@
def describe_log_streams(log_stream_name_prefix, log_streams = nil, next_token = nil)
request = {
log_group_name: @log_group_name
}
request[:next_token] = next_token if next_token
- request[:log_stream_name_prefix] = log_stream_name_prefix
+ request[:log_stream_name_prefix] = log_stream_name_prefix if log_stream_name_prefix
response = @logs.describe_log_streams(request)
if log_streams
log_streams.concat(response.log_streams)
else
log_streams = response.log_streams