diff --git a/pkg/tsdb/cloudwatch/metric_find_query.go b/pkg/tsdb/cloudwatch/metric_find_query.go index 8ff2f1ccf48..5f91f118cad 100644 --- a/pkg/tsdb/cloudwatch/metric_find_query.go +++ b/pkg/tsdb/cloudwatch/metric_find_query.go @@ -274,7 +274,7 @@ func (e *cloudWatchExecutor) resourceGroupsGetResources(ctx context.Context, plu } var resp resourcegroupstaggingapi.GetResourcesOutput - if err := client.GetResourcesPages(params, + if err := client.GetResourcesPagesWithContext(ctx, params, func(page *resourcegroupstaggingapi.GetResourcesOutput, lastPage bool) bool { resp.ResourceTagMappingList = append(resp.ResourceTagMappingList, page.ResourceTagMappingList...) return !lastPage diff --git a/pkg/tsdb/cloudwatch/test_utils.go b/pkg/tsdb/cloudwatch/test_utils.go index 7b41c9f98ec..9dff03b03bf 100644 --- a/pkg/tsdb/cloudwatch/test_utils.go +++ b/pkg/tsdb/cloudwatch/test_utils.go @@ -187,8 +187,8 @@ type fakeRGTAClient struct { tagMapping []*resourcegroupstaggingapi.ResourceTagMapping } -func (c fakeRGTAClient) GetResourcesPages(in *resourcegroupstaggingapi.GetResourcesInput, - fn func(*resourcegroupstaggingapi.GetResourcesOutput, bool) bool) error { +func (c fakeRGTAClient) GetResourcesPagesWithContext(ctx context.Context, in *resourcegroupstaggingapi.GetResourcesInput, + fn func(*resourcegroupstaggingapi.GetResourcesOutput, bool) bool, opts ...request.Option) error { fn(&resourcegroupstaggingapi.GetResourcesOutput{ ResourceTagMappingList: c.tagMapping, }, true)