Skip to content

Commit

Permalink
postgres escape column name in updated_at_rows query
Browse files Browse the repository at this point in the history
This is necessary if, for example, the column name is not all lowercase
  • Loading branch information
austinweisgrau committed Oct 6, 2024
1 parent 2c91104 commit dffb2c2
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion parsons/databases/postgres/postgres.py
Original file line number Diff line number Diff line change
Expand Up @@ -129,7 +129,7 @@ def get_updated_rows(
parameters = []

if cutoff_value is not None:
sql += f"WHERE {updated_at_column} > %s"
sql += f'WHERE "{updated_at_column}" > %s'
parameters.append(cutoff_value)

if chunk_size:
Expand Down

0 comments on commit dffb2c2

Please sign in to comment.