From 6621280ffc401e9470f51d56d8c0c6f2bcda8bfd Mon Sep 17 00:00:00 2001
From: Kishore Nallan <kishorenc@gmail.com>
Date: Tue, 14 Sep 2021 08:50:06 +0530
Subject: [PATCH] Don't consider failed imports for progress calculation.

---
 src/batched_indexer.cpp | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/batched_indexer.cpp b/src/batched_indexer.cpp
index 0ab631bc..9593e765 100644
--- a/src/batched_indexer.cpp
+++ b/src/batched_indexer.cpp
@@ -44,7 +44,6 @@ void BatchedIndexer::enqueue(const std::shared_ptr<http_req>& req, const std::sh
     //LOG(INFO) << "req_id: " << req->start_ts << ", chunk_sequence: " << chunk_sequence;
 
     store->insert(request_chunk_key, req->serialize());
-    queued_writes++;
     req->body = "";
 
     {
@@ -62,6 +61,8 @@ void BatchedIndexer::enqueue(const std::shared_ptr<http_req>& req, const std::sh
     if(req->last_chunk_aggregate) {
         //LOG(INFO) << "Last chunk for req_id: " << req->start_ts << ", queue_id: " << queue_id;
 
+        queued_writes += (chunk_sequence + 1);
+
         {
             std::unique_lock lk(qmutuxes[queue_id]);
             queues[queue_id].emplace_back(req->start_ts);