fix: Fixed NotFound errors exceptions for some resources (#965)

cloudquery · May 31, 2022 · d2cab56 · d2cab56
1 parent 8d73ea6
commit d2cab56
Show file tree

Hide file tree

Showing 5 changed files with 15 additions and 0 deletions.
diff --git a/resources/services/apigateway/rest_apis.go b/resources/services/apigateway/rest_apis.go
@@ -868,6 +868,9 @@ func fetchApigatewayRestApiModels(ctx context.Context, meta schema.ClientMeta, p
 			options.Region = c.Region
 		})
 		if err != nil {
+			if c.IsNotFoundError(err) {
+				return nil
+			}
 			return diag.WrapError(err)
 		}
 		res <- response.Items

diff --git a/resources/services/elbv2/listeners.go b/resources/services/elbv2/listeners.go
@@ -359,6 +359,9 @@ func fetchElbv2Listeners(ctx context.Context, meta schema.ClientMeta, parent *sc
 			options.Region = c.Region
 		})
 		if err != nil {
+			if c.IsNotFoundError(err) {
+				return nil
+			}
 			return diag.WrapError(err)
 		}
 		res <- response.Listeners

diff --git a/resources/services/kms/keys.go b/resources/services/kms/keys.go
@@ -213,6 +213,9 @@ func fetchKmsKeys(ctx context.Context, meta schema.ClientMeta, parent *schema.Re
 				options.Region = c.Region
 			})
 			if err != nil {
+				if c.IsNotFoundError(err) {
+					continue
+				}
 				return diag.WrapError(err)
 			}
 			if d.KeyMetadata != nil {

diff --git a/resources/services/lambda/functions.go b/resources/services/lambda/functions.go
@@ -1324,6 +1324,9 @@ func fetchLambdaFunctionVersions(ctx context.Context, meta schema.ClientMeta, pa
 	for {
 		output, err := svc.ListVersionsByFunction(ctx, &config)
 		if err != nil {
+			if meta.(*client.Client).IsNotFoundError(err) {
+				return nil
+			}
 			return diag.WrapError(err)
 		}
 		res <- output.Versions

diff --git a/resources/services/rds/cluster_snapshots.go b/resources/services/rds/cluster_snapshots.go
@@ -205,6 +205,9 @@ func resolveRDSClusterSnapshotAttributes(ctx context.Context, meta schema.Client
 		},
 	)
 	if err != nil {
+		if c.IsNotFoundError(err) {
+			return nil
+		}
 		return diag.WrapError(err)
 	}
 	if out.DBClusterSnapshotAttributesResult == nil {