aboutsummaryrefslogtreecommitdiffstats
path: root/src/extract_lambda.py
diff options
context:
space:
mode:
authorAlex Schofield <git@ajschof.me>2024-08-19 23:26:58 +0100
committerAlex Schofield <git@ajschof.me>2024-08-19 23:26:58 +0100
commit610d23e7ed0f39e5ecb0dd25c3a1e3cba20d662e (patch)
treea35e92c9a8b4f6e0808fb1a795303fe54044d5ae /src/extract_lambda.py
parentcaed81dc699b9b4105da2b8924310f1a370217c7 (diff)
downloadde-project-bentley-610d23e7ed0f39e5ecb0dd25c3a1e3cba20d662e.tar.gz
de-project-bentley-610d23e7ed0f39e5ecb0dd25c3a1e3cba20d662e.zip
refactor: remove print statements in process_and_upload_tables
Diffstat (limited to 'src/extract_lambda.py')
-rw-r--r--src/extract_lambda.py2
1 files changed, 0 insertions, 2 deletions
diff --git a/src/extract_lambda.py b/src/extract_lambda.py
index ad3c970..7c6c3d1 100644
--- a/src/extract_lambda.py
+++ b/src/extract_lambda.py
@@ -159,13 +159,11 @@ def process_and_upload_tables(db, existing_files, client=boto3.client("s3")):
)
for table in tables:
- print(tables)
table_name = table[0]
rows = db.run(
f"SELECT * FROM {identifier(table_name)} WHERE last_updated >= :latest;",
latest={datetime.strftime(latest_timestamp, "%Y-%m-%d %H:%M:%S")},
)
- print("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"
git.ajschof.me — hosted by ajschofield — powered by cgit