diff options
| author | Ellie <ecsymonds@gmail.com> | 2024-08-19 16:33:26 +0100 |
|---|---|---|
| committer | Ellie <ecsymonds@gmail.com> | 2024-08-19 16:33:26 +0100 |
| commit | 982b8fa318c9065bd9037d14c56abcd126252978 (patch) | |
| tree | 12f708968b3e413ad96143b53ee60d9c7341fa6a /src | |
| parent | 333822a70640712ac57036d37f7d8ac0787e9cc0 (diff) | |
| download | de-project-bentley-982b8fa318c9065bd9037d14c56abcd126252978.tar.gz de-project-bentley-982b8fa318c9065bd9037d14c56abcd126252978.zip | |
add working process and upload tables test
Diffstat (limited to 'src')
| -rw-r--r-- | src/extract_lambda.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/extract_lambda.py b/src/extract_lambda.py index 533bf82..5a5a631 100644 --- a/src/extract_lambda.py +++ b/src/extract_lambda.py @@ -150,8 +150,8 @@ def process_and_upload_tables(db, existing_files, client=boto3.client("s3")): print(tables) table_name = table[0] rows = db.run( - f"SELECT * FROM {identifier(table_name)} " "WHERE last_updated >= :latest;", - latest={datetime.strftime(latest_timestamp, "%H-%m-%d %H:%M:%S")}, + 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 |