sql syntax error

ehigham · ehigham · commit 7a3a33c58651 · 2024-07-31T13:13:18.000-04:00
diff --git a/batch/batch/driver/main.py b/batch/batch/driver/main.py
@@ -1613,7 +1613,7 @@ async def delete_dead_job_group_cancellable_resources_records(db: Database):
         await db.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])};
 """,
             [target[k] for k in keyfields],
         )

Original file line number	Diff line number	Diff line change
`@@ -1613,7 +1613,7 @@ async def delete_dead_job_group_cancellable_resources_records(db: Database):`
`1613`	`1613`	`await db.just_execute(`
`1614`	`1614`	`f"""\`
`1615`	`1615`	`DELETE FROM job_group_inst_coll_cancellable_resources`
`1616`		`-WHERE {','.join([f'{k} = %s' for k in keyfields])};`
	`1616`	`+WHERE {'AND'.join([f'{k} = %s' for k in keyfields])};`
`1617`	`1617`	`""",`
`1618`	`1618`	`[target[k] for k in keyfields],`
`1619`	`1619`	`)`