Skip to content

Commit 68b1097

Browse files
committed
feat: enhance mutation manager job to support database specification in ClickHouse queries
1 parent d08b522 commit 68b1097

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

api/jobs/mutationManagerJob.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -496,7 +496,7 @@ class MutationManagerJob extends Job {
496496
const commandId = `um_${String(task._id)}_${retryIndex}`; // update mutation
497497
await common.queryRunner.executeQuery(
498498
queryDef,
499-
{ queryObj: task.query, updateObj: task.update, targetTable: task.collection, validation_command_id: commandId },
499+
{ queryObj: task.query, updateObj: task.update, targetTable: task.collection, db: task.db, validation_command_id: commandId },
500500
{}
501501
);
502502
await common.db.collection("mutation_manager").updateOne(

0 commit comments

Comments
 (0)