Skip to content

Commit 208672b

Browse files
committed
Fix max_pk query
1 parent fafcd75 commit 208672b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/sbosc/controller/controller.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -65,8 +65,8 @@ def create_bulk_import_chunks(self):
6565
metadata = self.redis_data.metadata
6666
with self.db.cursor(role="reader") as cursor:
6767
cursor.execute('''
68-
SELECT MIN(%s), MAX(%s) FROM %s.%s
69-
''' % (metadata.pk_column, metadata.pk_column, metadata.source_db, metadata.source_table))
68+
SELECT MAX(%s) FROM %s.%s
69+
''' % (metadata.pk_column, metadata.source_db, metadata.source_table))
7070
max_pk = cursor.fetchone()[0]
7171
if max_pk is None:
7272
raise Exception("No data in source table")

0 commit comments

Comments
 (0)