Skip to content

Commit 59f2ddd

Browse files
Refactor access configuration loading and error handling in EventBridge writer for improved readability and maintainability
1 parent d98a7ad commit 59f2ddd

File tree

2 files changed

+6
-5
lines changed

2 files changed

+6
-5
lines changed

src/event_gate_lambda.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -68,9 +68,7 @@
6868
name_parts = CONFIG["access_config"].split("/")
6969
BUCKET_NAME = name_parts[2]
7070
BUCKET_OBJECT_KEY = "/".join(name_parts[3:])
71-
ACCESS = json.loads(
72-
aws_s3.Bucket(BUCKET_NAME).Object(BUCKET_OBJECT_KEY).get()["Body"].read().decode("utf-8")
73-
)
71+
ACCESS = json.loads(aws_s3.Bucket(BUCKET_NAME).Object(BUCKET_OBJECT_KEY).get()["Body"].read().decode("utf-8"))
7472
else:
7573
with open(CONFIG["access_config"], "r", encoding="utf-8") as file:
7674
ACCESS = json.load(file)

src/writer_eventbridge.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -67,8 +67,11 @@ def write(topic_name: str, message: Dict[str, Any]) -> Tuple[bool, Optional[str]
6767
logger.error(err_msg)
6868
return False, err_msg
6969
except Exception as err: # pragma: no cover - unexpected failure path
70-
err_msg = f"The EventBridge writer failed with unknown error: {err}" \
71-
if not isinstance(err, (BotoCoreError, ClientError)) else str(err)
70+
err_msg = (
71+
f"The EventBridge writer failed with unknown error: {err}"
72+
if not isinstance(err, (BotoCoreError, ClientError))
73+
else str(err)
74+
)
7275
logger.error(err_msg)
7376
return False, err_msg
7477

0 commit comments

Comments
 (0)