Skip to content

Commit cbbaa30

Browse files
committed
shared s3 client II
1 parent 17a662a commit cbbaa30

File tree

5 files changed

+6
-8
lines changed

5 files changed

+6
-8
lines changed

lambdas/filenameprocessor/src/file_name_processor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
from uuid import uuid4
1111

1212
from audit_table import upsert_audit_table
13-
from common.clients import STREAM_NAME, logger, get_s3_client
13+
from common.clients import STREAM_NAME, get_s3_client, logger
1414
from common.log_decorator import logging_decorator
1515
from common.models.errors import UnhandledAuditTableError
1616
from constants import (

lambdas/filenameprocessor/src/utils_for_filenameprocessor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
from datetime import timedelta
44

5-
from common.clients import logger, get_s3_client
5+
from common.clients import get_s3_client, logger
66
from constants import AUDIT_TABLE_TTL_DAYS
77

88

lambdas/mesh_processor/src/converter.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,14 @@
1-
import logging
21
import os
32
from typing import BinaryIO
43

5-
import boto3
64
from smart_open import open
75

6+
from common.clients import get_s3_client, logger
7+
88
EXPECTED_BUCKET_OWNER_ACCOUNT = os.getenv("ACCOUNT_ID")
99
DESTINATION_BUCKET_NAME = os.getenv("DESTINATION_BUCKET_NAME")
1010
UNEXPECTED_EOF_ERROR = "Unexpected EOF"
1111

12-
from common.clients import logger, get_s3_client
13-
1412

1513
def parse_headers(headers_str: str) -> dict[str, str]:
1614
headers = dict( # NOSONAR(S7494) force this to dict

lambdas/recordprocessor/src/file_level_validation.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
from csv import DictReader
77

88
from audit_table import update_audit_table_status
9-
from common.clients import logger, get_s3_client
9+
from common.clients import get_s3_client, logger
1010
from constants import (
1111
ARCHIVE_DIR_NAME,
1212
EXPECTED_CSV_HEADERS,

lambdas/shared/src/common/s3_reader.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
from common.clients import logger, get_s3_client
1+
from common.clients import get_s3_client, logger
22

33

44
class S3Reader:

0 commit comments

Comments
 (0)