diff options
| author | Alex Schofield <git@ajschof.me> | 2024-08-20 11:49:59 +0100 |
|---|---|---|
| committer | Alex Schofield <git@ajschof.me> | 2024-08-20 11:49:59 +0100 |
| commit | be911e22a964bdf7d5a4421cde7d7c6df447ed5c (patch) | |
| tree | b4346cfd4844c6b998accb010274e1eec93f6d86 /src/extract_lambda.py | |
| parent | 35397e8bad42a8c507d1fb13007c6da2f947e851 (diff) | |
| download | de-project-bentley-be911e22a964bdf7d5a4421cde7d7c6df447ed5c.tar.gz de-project-bentley-be911e22a964bdf7d5a4421cde7d7c6df447ed5c.zip | |
refactor: change rows output to debug logger output
Diffstat (limited to 'src/extract_lambda.py')
| -rw-r--r-- | src/extract_lambda.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/extract_lambda.py b/src/extract_lambda.py index fe22192..e9f438b 100644 --- a/src/extract_lambda.py +++ b/src/extract_lambda.py @@ -16,7 +16,6 @@ logging.basicConfig( datefmt="%Y-%m-%d %H:%M", level=logging.INFO, ) -# DB Exception class class DBConnectionException(Exception): @@ -187,7 +186,7 @@ def process_and_upload_tables(db, existing_files, client=boto3.client("s3")): logger.info(f"Processing table: {table_name}") logger.info(f"Latest timestamp: {latest[0]}") rows = db.run(base_query, latest=latest) - logger.info(f"Rows: {rows}") + logger.debug(f"Rows: {rows}") # Creating a temporary file path and writing the column name to it followed by each row of data if rows: csv_file_path = f"/tmp/{table_name}.csv" |