From 00bc7036c2f4aab7cf0793533687ba91d3eadb2c Mon Sep 17 00:00:00 2001
From: LJ <linghua@cocoindex.io>
Date: Sat, 12 Apr 2025 09:53:54 -0700
Subject: [PATCH] Count error when there is failure during processing.

---
 src/execution/source_indexer.rs | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/execution/source_indexer.rs b/src/execution/source_indexer.rs
index d4c3e62ea..6c4846dd0 100644
--- a/src/execution/source_indexer.rs
+++ b/src/execution/source_indexer.rs
@@ -87,7 +87,7 @@ impl SourceIndexingContext {
         processing_sem: Arc<Semaphore>,
         pool: PgPool,
     ) {
-        let process = async move {
+        let process = async {
             let permit = processing_sem.acquire().await?;
             let plan = self.flow.get_execution_plan().await?;
             let import_op = &plan.import_ops[self.source_idx];
@@ -157,6 +157,7 @@ impl SourceIndexingContext {
             anyhow::Ok(())
         };
         if let Err(e) = process.await {
+            update_stats.num_errors.inc(1);
             error!("{:?}", e.context("Error in processing a source row"));
         }
     }