diff --git a/parsons/databases/postgres/postgres.py b/parsons/databases/postgres/postgres.py index 833d4a7d22..18c2a61135 100644 --- a/parsons/databases/postgres/postgres.py +++ b/parsons/databases/postgres/postgres.py @@ -125,7 +125,6 @@ def get_updated_rows( sql = f""" SELECT * FROM {self.table} - WHERE "{updated_at_column}" > %s """ parameters = [] @@ -138,6 +137,6 @@ def get_updated_rows( sql += f" OFFSET {offset}" - result = self.db.query(sql, parameters=[cutoff_value]) + result = self.db.query(sql, parameters=parameters) return result