mirror of
https://github.com/ghndrx/prowler.git
synced 2026-02-10 14:55:00 +00:00
fix(service errors): solve EMR, VPC and ELBv2 service errors (#1974)
This commit is contained in:
@@ -1,6 +1,7 @@
|
|||||||
import threading
|
import threading
|
||||||
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
|
||||||
@@ -137,7 +138,11 @@ class ELBv2:
|
|||||||
conditions=rule["Conditions"],
|
conditions=rule["Conditions"],
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
except ClientError as error:
|
||||||
|
if error.response["Error"]["Code"] == "ListenerNotFound":
|
||||||
|
logger.warning(
|
||||||
|
f"{error.__class__.__name__}[{error.__traceback__.tb_lineno}]: {error}"
|
||||||
|
)
|
||||||
except Exception as error:
|
except Exception as error:
|
||||||
logger.error(
|
logger.error(
|
||||||
f"{regional_client.region} -- {error.__class__.__name__}[{error.__traceback__.tb_lineno}]: {error}"
|
f"{regional_client.region} -- {error.__class__.__name__}[{error.__traceback__.tb_lineno}]: {error}"
|
||||||
|
|||||||
@@ -79,7 +79,7 @@ class EMR:
|
|||||||
# Master Node Security Groups
|
# Master Node Security Groups
|
||||||
master_node_security_group = cluster_info["Cluster"][
|
master_node_security_group = cluster_info["Cluster"][
|
||||||
"Ec2InstanceAttributes"
|
"Ec2InstanceAttributes"
|
||||||
]["EmrManagedMasterSecurityGroup"]
|
].get("EmrManagedMasterSecurityGroup")
|
||||||
master_node_additional_security_groups = None
|
master_node_additional_security_groups = None
|
||||||
if (
|
if (
|
||||||
"AdditionalMasterSecurityGroups"
|
"AdditionalMasterSecurityGroups"
|
||||||
@@ -171,7 +171,7 @@ class ClusterStatus(Enum):
|
|||||||
|
|
||||||
|
|
||||||
class Node(BaseModel):
|
class Node(BaseModel):
|
||||||
security_group_id: str = ""
|
security_group_id: Optional[str] = ""
|
||||||
additional_security_groups_id: Optional[list[str]] = []
|
additional_security_groups_id: Optional[list[str]] = []
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -249,7 +249,7 @@ class VpcEndpoint(BaseModel):
|
|||||||
id: str
|
id: str
|
||||||
vpc_id: str
|
vpc_id: str
|
||||||
state: str
|
state: str
|
||||||
policy_document: dict
|
policy_document: Optional[dict]
|
||||||
owner_id: str
|
owner_id: str
|
||||||
region: str
|
region: str
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user