diff options
| author | lian-manonog <160282780+lian-manonog@users.noreply.github.com> | 2024-08-27 10:48:56 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-08-27 10:48:56 +0100 |
| commit | c610d3fc42a610ca5daff80606f8e67f9d1e20f2 (patch) | |
| tree | 9a7d397028986693923c9b7169d142c34a783cb0 /src/transform_lambda.py | |
| parent | 5c236c6ee0d0b7e0612a51bf8eaa59322d192a6e (diff) | |
| parent | e51e9fc3c7fa886fe5e753bd123d45c8871673bc (diff) | |
| download | de-project-bentley-c610d3fc42a610ca5daff80606f8e67f9d1e20f2.tar.gz de-project-bentley-c610d3fc42a610ca5daff80606f8e67f9d1e20f2.zip | |
Merge pull request #97 from ajschofield/test/test_transform_lambda
PR: mergeing test_transform_lambda to dev
Diffstat (limited to 'src/transform_lambda.py')
| -rw-r--r-- | src/transform_lambda.py | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/transform_lambda.py b/src/transform_lambda.py index defa15d..2cd9272 100644 --- a/src/transform_lambda.py +++ b/src/transform_lambda.py @@ -5,7 +5,7 @@ import logging import pandas as pd import pyarrow as pa import pyarrow.parquet as pq -from src.dataframes import * +from dataframes import * from botocore.exceptions import ClientError from pg8000.native import Connection, InterfaceError from datetime import datetime @@ -207,5 +207,10 @@ def list_existing_s3_files(bucket_name, client=boto3.client("s3")): except ClientError as e: logger.error(f"Error listing S3 objects: {e}") + raise e return existing_files + + +if __name__ == "__main__": + lambda_handler({}, "") |