fix invalid safety limit

mtanda · Oct 25, 2019 · 00cb66e · 00cb66e
1 parent b31cf5c
commit 00cb66e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/datasource.go b/datasource.go
@@ -374,7 +374,7 @@ func (t *AwsCloudWatchLogsDatasource) getLogEvent(tsdbReq *datasource.Datasource
 		err = svc.FilterLogEventsPages(input,
 			func(page *cloudwatchlogs.FilterLogEventsOutput, lastPage bool) bool {
 				resp.Events = append(resp.Events, page.Events...)
-				if len(resp.Events) > 1000 {
+				if len(resp.Events) > 10000 {
 					return false // safety limit
 				}
 				if int64(len(resp.Events)) >= *input.Limit {
@@ -402,7 +402,7 @@ func (t *AwsCloudWatchLogsDatasource) getLogEvent(tsdbReq *datasource.Datasource
 					}
 					resp.Events = append(resp.Events, fe)
 				}
-				if len(resp.Events) > 1000 {
+				if len(resp.Events) > 10000 {
 					return false // safety limit
 				}
 				if int64(len(resp.Events)) >= *input.Limit {