From cbcf6c9ba371614de222d03344cba7ab84ed7ab4 Mon Sep 17 00:00:00 2001 From: Tamo Date: Wed, 4 Dec 2024 14:48:48 +0100 Subject: [PATCH] make the processing tasks as processing in a batch --- crates/index-scheduler/src/lib.rs | 2 +- crates/index-scheduler/src/utils.rs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/crates/index-scheduler/src/lib.rs b/crates/index-scheduler/src/lib.rs index 5e0e4f97a..2d953fc6e 100644 --- a/crates/index-scheduler/src/lib.rs +++ b/crates/index-scheduler/src/lib.rs @@ -4335,7 +4335,7 @@ mod tests { "stats": { "totalNbTasks": 2, "status": { - "enqueued": 2 + "processing": 2 }, "types": { "indexCreation": 2 diff --git a/crates/index-scheduler/src/utils.rs b/crates/index-scheduler/src/utils.rs index fc41d535c..356d77b35 100644 --- a/crates/index-scheduler/src/utils.rs +++ b/crates/index-scheduler/src/utils.rs @@ -67,7 +67,7 @@ impl ProcessingBatch { task.batch_uid = Some(self.uid); // We don't store the statuses in the map since they're all enqueued but we must // still store them in the stats since that can be displayed. - *self.stats.status.entry(task.status).or_default() += 1; + *self.stats.status.entry(Status::Processing).or_default() += 1; self.kinds.insert(task.kind.as_kind()); *self.stats.types.entry(task.kind.as_kind()).or_default() += 1;