From 6f7b7e9db4b2dc1f3fc5d68ee4f0fb2899f8668e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?P=C4=B1nar=20Gen=C3=A7?= Date: Wed, 22 Oct 2025 17:46:43 +0300 Subject: [PATCH] fix: [deletion-manager] log & retry implementation for mongo deletion process --- api/jobs/deletionManagerJob.js | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/api/jobs/deletionManagerJob.js b/api/jobs/deletionManagerJob.js index c3fe257d6e3..5174988c1cf 100644 --- a/api/jobs/deletionManagerJob.js +++ b/api/jobs/deletionManagerJob.js @@ -280,15 +280,19 @@ class DeletionManagerJob extends Job { } let res; + const start = Date.now(); try { res = await common.drillDb.collection(task.collection).deleteMany(task.query || {}); } catch (err) { - await this.markFailedOrRetry(task, "mongo_delete_error: " + err?.message || err + ""); + const duration = Date.now() - start; + log.e("Mongo deletion failed", { taskId: task._id, durationMs: duration, error: (err?.message || err + "") }); + await this.markFailedOrRetry(task, "mongo_delete_error: " + (err?.message || err + "")); return false; } - log.d("Mongo deletion done", { taskId: task._id, deletedCount: res?.deletedCount || 0 }); + const duration = Date.now() - start; + log.d("Mongo deletion done", { taskId: task._id, deletedCount: res?.deletedCount || 0, durationMs: duration }); return true; }