Skip to content

Commit e012bb0

Browse files
committed
sql syntax error
1 parent 7a3a33c commit e012bb0

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

batch/batch/driver/main.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1518,7 +1518,7 @@ async def compact(tx: Transaction, record: dict):
15181518
await tx.just_execute(
15191519
f"""\
15201520
DELETE FROM job_group_inst_coll_cancellable_resources
1521-
WHERE {'AND'.join([f'{k} = %s' for k in keyfields])};
1521+
WHERE {' AND '.join([f'{k} = %s' for k in keyfields])};
15221522
""",
15231523
[record[k] for k in keyfields],
15241524
)
@@ -1613,7 +1613,7 @@ async def delete_dead_job_group_cancellable_resources_records(db: Database):
16131613
await db.just_execute(
16141614
f"""\
16151615
DELETE FROM job_group_inst_coll_cancellable_resources
1616-
WHERE {'AND'.join([f'{k} = %s' for k in keyfields])};
1616+
WHERE {' AND '.join([f'{k} = %s' for k in keyfields])};
16171617
""",
16181618
[target[k] for k in keyfields],
16191619
)

0 commit comments

Comments
 (0)