Changed-lines coverage: PR changed C/C++ lines covered by tests: 90.34% (767/849) Uncovered changed code (with context): ================================================================================ src/Common/ProfileEvents.cpp ================================================================================ --- uncovered block 1769-1771 --- 1767 | Counters::Snapshot & Counters::Snapshot::operator=(const Snapshot & other) 1768 | { >> 1769 | Snapshot tmp(other); >> 1770 | counters_holder = std::move(tmp.counters_holder); >> 1771 | return *this; 1772 | } 1773 | ================================================================================ src/Common/SelfContained.h ================================================================================ --- uncovered block 54-54 --- 52 | constexpr SelfContainedStatus worse(SelfContainedStatus a, SelfContainedStatus b) 53 | { >> 54 | return static_cast(a) >= static_cast(b) ? a : b; 55 | } 56 | ================================================================================ src/Common/SystemLogBase.cpp ================================================================================ --- uncovered block 355-355 --- 353 | } 354 | >> 355 | saving_thread->join(); 356 | } 357 | ================================================================================ src/Disks/IO/CachedOnDiskReadBufferFromFile.cpp ================================================================================ --- uncovered block 188-188 --- 186 | { 187 | if (!cache_log) >> 188 | return; 189 | 190 | const auto range = file_segment.range(); --- uncovered block 210-217 --- 208 | switch (type) 209 | { >> 210 | case CachedOnDiskReadBufferFromFile::ReadType::NONE: 211 | throw Exception(ErrorCodes::LOGICAL_ERROR, "Read type cannot be None"); 212 | case CachedOnDiskReadBufferFromFile::ReadType::CACHED: 213 | element.cache_type = FilesystemCacheLogElement::CacheType::READ_FROM_CACHE; 214 | break; >> 215 | case CachedOnDiskReadBufferFromFile::ReadType::REMOTE_FS_READ_BYPASS_CACHE: >> 216 | element.cache_type = FilesystemCacheLogElement::CacheType::READ_FROM_FS_BYPASSING_CACHE; >> 217 | break; 218 | case CachedOnDiskReadBufferFromFile::ReadType::REMOTE_FS_READ_AND_PUT_IN_CACHE: 219 | element.cache_type = FilesystemCacheLogElement::CacheType::READ_FROM_FS_AND_DOWNLOADED_TO_CACHE; ================================================================================ src/Disks/IO/CachedOnDiskWriteBufferFromFile.cpp ================================================================================ --- uncovered block 353-370 --- 351 | return; 352 | >> 353 | size_t file_segment_right_bound = file_segment_range.left + file_segment.getDownloadedSize() - 1; 354 | >> 355 | cache_log->add([&](FilesystemCacheLogElement & element) 356 | { >> 357 | element = FilesystemCacheLogElement 358 | { >> 359 | .event_time = std::chrono::system_clock::to_time_t(std::chrono::system_clock::now()), >> 360 | .query_id = query_id, >> 361 | .source_file_path = source_path, >> 362 | .file_segment_range = { file_segment_range.left, file_segment_right_bound }, >> 363 | .requested_range = {}, >> 364 | .cache_type = FilesystemCacheLogElement::CacheType::WRITE_THROUGH_CACHE, >> 365 | .file_segment_key = {}, >> 366 | .file_segment_size = file_segment_range.size(), >> 367 | .read_from_cache_attempted = false, >> 368 | .read_buffer_id = {}, 369 | }; >> 370 | }); 371 | } 372 | ================================================================================ src/Interpreters/CrashLog.cpp ================================================================================ --- uncovered block 136-157 --- 134 | 0, 135 | current_exception_trace_size, >> 136 | [¤t_exception_trace_full](std::string_view line) { current_exception_trace_full.push_back(line); }); 137 | } 138 | >> 139 | crash_log_owned->add([&](CrashLogElement & element) 140 | { >> 141 | element = CrashLogElement{ >> 142 | static_cast(time / 1000000000), >> 143 | time, >> 144 | signal, >> 145 | signal_code, >> 146 | thread_id, >> 147 | query_id, >> 148 | query, >> 149 | trace, >> 150 | trace_full, >> 151 | fault_address, >> 152 | fault_access_type, >> 153 | signal_description, >> 154 | current_exception_trace_full, >> 155 | GIT_HASH, >> 156 | Poco::Environment::osArchitecture()}; >> 157 | }); 158 | } 159 | } ================================================================================ src/Interpreters/DeltaMetadataLog.cpp ================================================================================ --- uncovered block 89-100 --- 87 | throw ErrnoException(ErrorCodes::CANNOT_CLOCK_GETTIME, "Cannot clock_gettime"); 88 | >> 89 | auto delta_lake_metadata_log = Context::getGlobalContextInstance()->getDeltaMetadataLog(); >> 90 | if (!delta_lake_metadata_log) >> 91 | throw Exception(ErrorCodes::BAD_ARGUMENTS, "Delta metadata log table is not configured"); >> 92 | delta_lake_metadata_log->add([&](DB::DeltaMetadataLogElement & element) 93 | { >> 94 | element = DB::DeltaMetadataLogElement{ >> 95 | .current_time = spec.tv_sec, >> 96 | .query_id = local_context->getCurrentQueryId(), >> 97 | .table_path = table_path, >> 98 | .file_path = file_path, >> 99 | .metadata_content = row}; >> 100 | }); 101 | } 102 | } ================================================================================ src/Interpreters/IcebergMetadataLog.cpp ================================================================================ --- uncovered block 105-119 --- 103 | if (!iceberg_metadata_log) 104 | { >> 105 | throw Exception(ErrorCodes::BAD_ARGUMENTS, "Iceberg metadata log table is not configured"); 106 | } 107 | >> 108 | iceberg_metadata_log->add([&](DB::IcebergMetadataLogElement & element) 109 | { >> 110 | element = DB::IcebergMetadataLogElement{ >> 111 | .current_time = spec.tv_sec, >> 112 | .query_id = local_context->getCurrentQueryId(), >> 113 | .content_type = row_log_level, 114 | .table_path = table_path, >> 115 | .file_path = file_path.serialize(), >> 116 | .metadata_content = row, >> 117 | .row_in_file = row_in_file, >> 118 | .pruning_status = pruning_status}; >> 119 | }); 120 | } 121 | } ================================================================================ src/Interpreters/InsertDependenciesBuilder.cpp ================================================================================ --- uncovered block 1603-1603 --- 1601 | const auto & thread_group = thread_groups.at(view_id); 1602 | if (!thread_group) >> 1603 | return; 1604 | 1605 | auto views_log = init_context->getQueryViewsLog(); --- uncovered block 1616-1616 --- 1614 | UInt64 min_query_duration = settings[Setting::log_queries_min_query_duration_ms].totalMilliseconds(); 1615 | if (min_query_duration && elapsed_ms <= min_query_duration) >> 1616 | return; 1617 | 1618 | try ================================================================================ src/Interpreters/MetricLog.cpp ================================================================================ --- uncovered block 111-111 --- 109 | /// - test_secure_socket::test 110 | if (new_value < old_value) >> 111 | continue; 112 | 113 | element.profile_events[i] = new_value - old_value; ================================================================================ src/Interpreters/executeQuery.cpp ================================================================================ --- uncovered block 999-999 --- 997 | query_log->add([&](QueryLogElement & e) { e = elem; }); 998 | } >> 999 | else if (!settings[Setting::log_queries]) 1000 | { 1001 | if (settings[Setting::log_queries].changed) ================================================================================ src/Processors/QueryPlan/ReadFromMergeTree.cpp ================================================================================ --- uncovered block 3797-3797 --- 3795 | auto storage_id = data.getStorageID(); 3796 | if (storage_id.database_name.empty()) >> 3797 | return; 3798 | 3799 | bool has_index_stats = false; --- uncovered block 3811-3812 --- 3809 | return; 3810 | >> 3811 | auto now = time(nullptr); >> 3812 | predicate_stats_log->add([&](PredicateStatisticsLogElement & element) 3813 | { 3814 | element.event_date = static_cast(DateLUT::instance().toDayNum(now)); --- uncovered block 3830-3830 --- 3828 | 3829 | if (!stat.part_name.empty()) >> 3830 | continue; 3831 | 3832 | UInt64 total = prev_granules > 0 ? prev_granules : stat.num_granules_after; ================================================================================ src/Storages/RabbitMQ/RabbitMQSource.cpp ================================================================================ --- uncovered block 328-334 --- 326 | 327 | auto dead_letter_queue = context->getDeadLetterQueue(); >> 328 | if (!dead_letter_queue) >> 329 | LOG_WARNING(log, "Table system.dead_letter_queue is not configured, skipping message"); 330 | else >> 331 | dead_letter_queue->add([&](DeadLetterQueueElement & element) { element = >> 332 | DeadLetterQueueElement{ >> 333 | .table_engine = DeadLetterQueueElement::StreamType::RabbitMQ, >> 334 | .event_time = timeInSeconds(time_now), 335 | .event_time_microseconds = timeInMicroseconds(time_now), 336 | .database = storage_id.database_name, --- uncovered block 345-348 --- 343 | .timestamp = message.timestamp, 344 | .redelivered = message.redelivered, >> 345 | .delivery_tag = message.delivery_tag, >> 346 | .channel_id = message.channel_id 347 | } >> 348 | }; }); 349 | } 350 | WARNING: Failed to get start time for [Print Uncovered Code] - start time and duration won't be set --- Coverage counts --- Lines : baseline 912,594/1,058,589 -> current 912,849/1,058,691 (delta +255 / +102) Functions : baseline 801,505/870,938 -> current 801,637/871,072 (delta +132 / +134) Branches : baseline 294,884/376,540 -> current 294,953/376,558 (delta +69 / +18)