mirror of
https://github.com/ghndrx/prowler.git
synced 2026-02-10 14:55:00 +00:00
fix(emr): Handle InvalidRequestException (#2320)
This commit is contained in:
@@ -2,6 +2,7 @@ import threading
|
|||||||
from enum import Enum
|
from enum import Enum
|
||||||
from typing import Optional
|
from typing import Optional
|
||||||
|
|
||||||
|
from botocore.client import ClientError
|
||||||
from pydantic import BaseModel
|
from pydantic import BaseModel
|
||||||
|
|
||||||
from prowler.lib.logger import logger
|
from prowler.lib.logger import logger
|
||||||
@@ -71,10 +72,19 @@ class EMR:
|
|||||||
try:
|
try:
|
||||||
for cluster in self.clusters.values():
|
for cluster in self.clusters.values():
|
||||||
if cluster.region == regional_client.region:
|
if cluster.region == regional_client.region:
|
||||||
describe_cluster_parameters = {"ClusterId": cluster.id}
|
try:
|
||||||
cluster_info = regional_client.describe_cluster(
|
describe_cluster_parameters = {"ClusterId": cluster.id}
|
||||||
**describe_cluster_parameters
|
cluster_info = regional_client.describe_cluster(
|
||||||
)
|
**describe_cluster_parameters
|
||||||
|
)
|
||||||
|
except ClientError as error:
|
||||||
|
if error.response["Error"]["Code"] == "InvalidRequestException":
|
||||||
|
logger.warning(
|
||||||
|
f"{regional_client.region} --"
|
||||||
|
f" {error.__class__.__name__}[{error.__traceback__.tb_lineno}]:"
|
||||||
|
f" {error}"
|
||||||
|
)
|
||||||
|
continue
|
||||||
|
|
||||||
# Master Node Security Groups
|
# Master Node Security Groups
|
||||||
master_node_security_group = cluster_info["Cluster"][
|
master_node_security_group = cluster_info["Cluster"][
|
||||||
|
|||||||
Reference in New Issue
Block a user