98.67% (74/75)

Uncovered changed code (with context):

================================================================================
src/Storages/ObjectStorageQueue/ObjectStorageQueueSource.cpp
================================================================================

--- uncovered block 1610-1610 ---
     1608 |     }
     1609 |     if (finalize_exception)
>>   1610 |         std::rethrow_exception(finalize_exception);
     1611 | }
     1612 | 

=== Lost Baseline Coverage: 11 lines ===

================================================================================
src/Storages/ObjectStorageQueue/ObjectStorageQueueSource.cpp
================================================================================

--- lost coverage block 292-293 ---
      290 |                     else
      291 |                     {
>>    292 |                         new_batch[i] = nullptr;
>>    293 |                         file_metadatas[i] = nullptr;
      294 |                     }
      295 |                 }

--- lost coverage block 331-333 ---
      329 |                                 if (response.error == Coordination::Error::ZNONODE)
      330 |                                 {
>>    331 |                                     LOG_TEST(log, "Path {} does not exist", processing_paths[i]);
>>    332 |                                     failed = true;
>>    333 |                                     break;
      334 |                                 }
      335 |                                 if (response.error == Coordination::Error::ZOK)

--- lost coverage block 373-373 ---
      371 |                     {
      372 |                         if (!new_batch[i])
>>    373 |                             continue;
      374 | 
      375 |                         file_metadatas[i]->afterSetProcessing(/* success */true, std::nullopt);

--- lost coverage block 392-393 ---
      390 |                 if (num_successful_objects != new_batch.size())
      391 |                 {
>>    392 |                     size_t batch_i = 0;
>>    393 |                     for (size_t i = 0; i < num_successful_objects; ++i, ++batch_i)
      394 |                     {
      395 |                         while (batch_i < new_batch.size() && !new_batch[batch_i])

--- lost coverage block 409-410 ---
      407 |                         file_metadatas[i] = file_metadatas[batch_i];
      408 |                     }
>>    409 |                     new_batch.resize(num_successful_objects);
>>    410 |                     file_metadatas.resize(num_successful_objects);
      411 |                 }
      412 | 
================================================================================
src/Storages/ObjectStorageQueue/StorageObjectStorageQueue.cpp
================================================================================

--- lost coverage block 738-738 ---
      736 | 
      737 |     if (shutdown_called)
>>    738 |         return;
      739 | 
      740 |     auto component_guard = Coordination::setCurrentComponent("StorageObjectStorageQueue::threadFunc");
WARNING: Failed to get start time for [Print Uncovered Code] - start time and duration won't be set

--- Coverage counts ---
Lines     : baseline 768,592/913,611  ->  current 768,696/913,635  (delta +104 / +24)
Functions : baseline 884,488/967,806  ->  current 884,509/967,806  (delta +21 / +0)
Branches  : baseline 250,802/327,570  ->  current 250,809/327,594  (delta +7 / +24)