diff --git a/plugins/source/aws/resources/services/ec2/images_fetch.go b/plugins/source/aws/resources/services/ec2/images_fetch.go index 51e2218b2fa76c..84f6d71b7d2734 100644 --- a/plugins/source/aws/resources/services/ec2/images_fetch.go +++ b/plugins/source/aws/resources/services/ec2/images_fetch.go @@ -19,21 +19,31 @@ func fetchEc2Images(ctx context.Context, meta schema.ClientMeta, parent *schema. g, ctx := errgroup.WithContext(ctx) g.Go(func() error { // fetch ec2.Images owned by this account - response, err := svc.DescribeImages(ctx, &ec2.DescribeImagesInput{Owners: []string{"self"}}) - if err != nil { - return err + pag := ec2.NewDescribeImagesPaginator(svc, &ec2.DescribeImagesInput{ + Owners: []string{"self"}, + }) + for pag.HasMorePages() { + resp, err := pag.NextPage(ctx) + if err != nil { + return err + } + res <- resp.Images } - res <- response.Images return nil }) g.Go(func() error { // fetch ec2.Images that are shared with this account - response, err := svc.DescribeImages(ctx, &ec2.DescribeImagesInput{ExecutableUsers: []string{"self"}}) - if err != nil { - return err + pag := ec2.NewDescribeImagesPaginator(svc, &ec2.DescribeImagesInput{ + ExecutableUsers: []string{"self"}, + }) + for pag.HasMorePages() { + resp, err := pag.NextPage(ctx) + if err != nil { + return err + } + res <- resp.Images } - res <- response.Images return nil })