diff --git a/parsons/databases/postgres/postgres.py b/parsons/databases/postgres/postgres.py index 87345b4143..833d4a7d22 100644 --- a/parsons/databases/postgres/postgres.py +++ b/parsons/databases/postgres/postgres.py @@ -127,6 +127,12 @@ def get_updated_rows( FROM {self.table} WHERE "{updated_at_column}" > %s """ + parameters = [] + + if cutoff_value is not None: + sql += f'WHERE "{updated_at_column}" > %s' + parameters.append(cutoff_value) + if chunk_size: sql += f" LIMIT {chunk_size}"