Skip to content

Commit 65fdd49

Browse files
committed
ruff
1 parent d0f081f commit 65fdd49

File tree

3 files changed

+7
-5
lines changed

3 files changed

+7
-5
lines changed

lambdas/filenameprocessor/src/audit_table.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ def upsert_audit_table(
1515
queue_name: str,
1616
file_status: str,
1717
error_details: Optional[str] = None,
18-
condition_expression: str = ""
18+
condition_expression: str = "",
1919
) -> None:
2020
"""
2121
Updates the audit table with the file details

lambdas/filenameprocessor/src/file_name_processor.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,9 +7,10 @@
77
"""
88

99
import argparse
10-
from botocore.exceptions import ClientError
1110
from uuid import uuid4
1211

12+
from botocore.exceptions import ClientError
13+
1314
from audit_table import upsert_audit_table
1415
from common.aws_s3_utils import (
1516
copy_file_outside_bucket,
@@ -249,7 +250,7 @@ def handle_extended_attributes_file(
249250
Processes a single record for extended attributes file.
250251
Returns a dictionary containing information to be included in the logs.
251252
"""
252-
253+
253254
# here: the sequence of events should be
254255
# 1. upsert 'processing'
255256
# 2. move the file to the dest bucket
@@ -314,8 +315,8 @@ def handle_extended_attributes_file(
314315
file_key,
315316
created_at_formatted_string,
316317
expiry_timestamp,
317-
extended_attribute_identifier,
318318
queue_name,
319+
file_status,
319320
error_details=str(error),
320321
)
321322

lambdas/shared/src/common/aws_s3_utils.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@ def copy_file_outside_bucket(source_bucket: str, source_key: str, destination_bu
2929
ExpectedSourceBucketOwner=EXPECTED_BUCKET_OWNER_ACCOUNT,
3030
)
3131

32+
3233
def delete_file(source_bucket: str, source_key: str) -> None:
3334
s3_client = get_s3_client()
3435
s3_client.delete_object(
@@ -37,7 +38,7 @@ def delete_file(source_bucket: str, source_key: str) -> None:
3738
ExpectedBucketOwner=EXPECTED_BUCKET_OWNER_ACCOUNT,
3839
)
3940

41+
4042
def is_file_in_bucket(bucket_name: str, file_key: str) -> None:
4143
s3_client = get_s3_client()
4244
s3_client.head_object(Bucket=bucket_name, Key=file_key)
43-

0 commit comments

Comments
 (0)