Skip to content

Commit 4d04600

Browse files
committed
Merge branch 'mr/trespeuch/ruff-pl0912' into 'master'
Fix remaining ruff PLR0912 violations See merge request it/e3-aws!146
2 parents 5d86435 + b825088 commit 4d04600

2 files changed

Lines changed: 16 additions & 25 deletions

File tree

src/e3/aws/troposphere/awslambda/__init__.py

Lines changed: 10 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -492,37 +492,27 @@ def lambda_resources(
492492
}
493493
)
494494

495-
if self.runtime is not None:
496-
params["Runtime"] = self.runtime
497-
498-
if self.handler is not None:
499-
params["Handler"] = self.handler
495+
optional_params = {
496+
"Runtime": self.runtime,
497+
"Handler": self.handler,
498+
"MemorySize": self.memory_size,
499+
"ReservedConcurrentExecutions": self.reserved_concurrent_executions,
500+
"LoggingConfig": self.logging_config,
501+
"DeadLetterConfig": self.dl_config,
502+
"VpcConfig": self.vpc_config,
503+
}
504+
params.update({k: v for k, v in optional_params.items() if v is not None})
500505

501506
if self.architecture is not None:
502507
params["Architectures"] = [self.architecture.value]
503508

504-
if self.memory_size is not None:
505-
params["MemorySize"] = self.memory_size
506-
507509
if self.ephemeral_storage_size is not None:
508510
params["EphemeralStorage"] = awslambda.EphemeralStorage(
509511
Size=self.ephemeral_storage_size
510512
)
511513
if self.environment is not None:
512514
params["Environment"] = awslambda.Environment(Variables=self.environment)
513515

514-
if self.reserved_concurrent_executions is not None:
515-
params["ReservedConcurrentExecutions"] = self.reserved_concurrent_executions
516-
517-
if self.logging_config is not None:
518-
params["LoggingConfig"] = self.logging_config
519-
520-
if self.dl_config is not None:
521-
params["DeadLetterConfig"] = self.dl_config
522-
523-
if self.vpc_config is not None:
524-
params["VpcConfig"] = self.vpc_config
525-
526516
result = [awslambda.Function(name_to_id(self.name), **params)]
527517
# If retention duration is given provide a log group.
528518
# If not provided the lambda creates a log group with

src/e3/aws/troposphere/awslambda/flask_apigateway_wrapper.py

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,6 @@ def create_flask_wsgi_environ(self, event: dict, context: dict) -> dict:
132132
"""
133133
del context
134134
request_ctx = event["requestContext"]
135-
remote_user: str | None = None
136135

137136
# http is True if the event comes from HTTP API gateway
138137
# otherwise it is false and the event is either from a REST API
@@ -141,10 +140,12 @@ def create_flask_wsgi_environ(self, event: dict, context: dict) -> dict:
141140
# elb is True if the event comes from ELB
142141
elb = "elb" in request_ctx
143142

144-
if "authorizer" in request_ctx:
145-
remote_user = request_ctx["authorizer"].get("principalId")
146-
elif "identity" in request_ctx:
147-
remote_user = request_ctx["identity"].get("userArn")
143+
# Falls back from authorizer to identity: if authorizer exists but has
144+
# no principalId, we still pick up identity.userArn rather than leaving
145+
# remote_user as None.
146+
remote_user: str | None = request_ctx.get("authorizer", {}).get(
147+
"principalId"
148+
) or request_ctx.get("identity", {}).get("userArn")
148149

149150
# Normalized headers
150151
headers = {k.title(): v for k, v in event["headers"].items()}

0 commit comments

Comments
 (0)