sql syntax error

ehigham · ehigham · commit 21e24216a900 · 2024-07-31T13:07:44.000-04:00
diff --git a/batch/batch/driver/main.py b/batch/batch/driver/main.py
@@ -1518,7 +1518,7 @@ async def compact(tx: Transaction, record: dict):
         await tx.just_execute(
             f"""\
 DELETE FROM job_group_inst_coll_cancellable_resources
-WHERE {','.join([f'{k} = %s' for k in keyfields])};
+WHERE {'AND'.join([f'{k} = %s' for k in keyfields])};
 """,
             [record[k] for k in keyfields],
         )

Original file line number	Diff line number	Diff line change
`@@ -1518,7 +1518,7 @@ async def compact(tx: Transaction, record: dict):`
`1518`	`1518`	`await tx.just_execute(`
`1519`	`1519`	`f"""\`
`1520`	`1520`	`DELETE FROM job_group_inst_coll_cancellable_resources`
`1521`		`-WHERE {','.join([f'{k} = %s' for k in keyfields])};`
	`1521`	`+WHERE {'AND'.join([f'{k} = %s' for k in keyfields])};`
`1522`	`1522`	`""",`
`1523`	`1523`	`[record[k] for k in keyfields],`
`1524`	`1524`	`)`