Skip to content

Commit

Permalink
fix s3 client invocation
Browse files Browse the repository at this point in the history
  • Loading branch information
solomon-negusse committed Jul 10, 2024
1 parent 88f074f commit 918fd66
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions lambdas/aggregation/src/lambda_function.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,14 +14,14 @@ def handler(event, context):
results_meta = event["distributed_map"]["ResultWriterDetails"]
try:
LOGGER.info(f"Running aggregate with parameters: {event}")
response = s3_client.get_object(
response = s3_client().get_object(
Bucket=results_meta["Bucket"], Key=results_meta["Key"]
)
manifest = json.loads(response["Body"].read().decode("utf-8"))
LOGGER.info("manifest file", manifest)

for result_record in manifest["ResultFiles"]["SUCCEEDED"]:
response = s3_client.get_object(
response = s3_client().get_object(
Bucket=results_meta["Bucket"], Key=result_record["Key"]
)
results = json.loads(response["Body"].read().decode("utf-8"))
Expand Down

0 comments on commit 918fd66

Please sign in to comment.