saksham115 · Nov 14, 2025 · Nov 14, 2025 · Dec 8, 2025 · Dec 8, 2025 · Dec 8, 2025
diff --git a/.lcovrc b/.lcovrc
@@ -1,4 +1,4 @@
-lcov_excl_line = LCOV_EXCL_LINE|KU_UNREACHABLE
+lcov_excl_line = LCOV_EXCL_LINE|RYU_UNREACHABLE
 geninfo_gcov_tool = gcov-13
 
 # Ignore errors that occur due to stricter validation in newer gcov versions (Ubuntu 24.04)

diff --git a/extension/algo/src/function/louvain.cpp b/extension/algo/src/function/louvain.cpp
@@ -495,7 +495,7 @@ void initInMemoryGraph(const table_id_t tableId, const offset_t numNodes, Graph*
     PhaseState& state) {
     const auto nbrTables = graph->getRelInfos(tableId);
     const auto nbrInfo = nbrTables[0];
-    KU_ASSERT(nbrInfo.srcTableID == nbrInfo.dstTableID);
+    RYU_ASSERT(nbrInfo.srcTableID == nbrInfo.dstTableID);
     // Set randomLookup to false to enable caching during graph materialization.
     const auto scanState = graph->prepareRelScan(*nbrInfo.relGroupEntry, nbrInfo.relTableID,
         nbrInfo.dstTableID, {}, false /*randomLookup*/);
@@ -578,7 +578,7 @@ static common::offset_t tableFunc(const TableFuncInput& input, TableFuncOutput&)
     auto mm = MemoryManager::Get(*clientContext);
     const auto graph = sharedState->graph.get();
     auto maxOffsetMap = graph->getMaxOffsetMap(transaction);
-    KU_ASSERT(graph->getNodeTableIDs().size() == 1);
+    RYU_ASSERT(graph->getNodeTableIDs().size() == 1);
     const auto tableID = graph->getNodeTableIDs()[0];
     const auto origNumNodes = graph->getMaxOffset(transaction, tableID);
 

diff --git a/extension/algo/src/function/spanning_forest.cpp b/extension/algo/src/function/spanning_forest.cpp
@@ -234,7 +234,7 @@ offset_t KruskalCompute::findComponent(const offset_t& nodeId) {
 }
 
 void KruskalCompute::mergeComponents(const offset_t& srcCompId, const offset_t& dstCompId) {
-    KU_ASSERT_UNCONDITIONAL(srcCompId != dstCompId);
+    RYU_ASSERT_UNCONDITIONAL(srcCompId != dstCompId);
     // Merge with the larger component, based on the rank. If ranks are equal, use IDs to break
     // ties.
     if (rank[srcCompId] == rank[dstCompId]) {
@@ -264,7 +264,7 @@ class WriteResultsSF final : public InMemResultParallelCompute {
 
     void parallelCompute(const offset_t startOffset, const offset_t endOffset,
         const std::optional<table_id_t>& tableID) override {
-        KU_ASSERT(tableID.has_value());
+        RYU_ASSERT(tableID.has_value());
         for (auto i = startOffset; i < endOffset; ++i) {
             const auto& [srcId, dstId, relId, forestId] = finalResults[i];
             relIdVector->setValue<relID_t>(0, relId);
@@ -293,12 +293,12 @@ static offset_t tableFunc(const TableFuncInput& input, TableFuncOutput&) {
     const auto clientContext = input.context->clientContext;
     auto sharedState = input.sharedState->ptrCast<GDSFuncSharedState>();
     auto graph = sharedState->graph.get();
-    KU_ASSERT(graph->getNodeTableIDs().size() == 1);
+    RYU_ASSERT(graph->getNodeTableIDs().size() == 1);
     const auto tableId = graph->getNodeTableIDs()[0];
     auto mm = MemoryManager::Get(*clientContext);
     const auto nbrTables = graph->getRelInfos(tableId);
     const auto nbrInfo = nbrTables[0];
-    KU_ASSERT(nbrInfo.srcTableID == nbrInfo.dstTableID);
+    RYU_ASSERT(nbrInfo.srcTableID == nbrInfo.dstTableID);
 
     auto spanningForestBindData = input.bindData->constPtrCast<SFBindData>();
     auto& config = spanningForestBindData->optionalParams->constCast<SFOptionalParams>();
@@ -405,7 +405,7 @@ static void getLogicalPlan(Planner* planner, const BoundReadingClause& readingCl
 
     for (auto i = 1u; i < 3; ++i) {
         auto nodeOutput = bindData->output[i]->ptrCast<NodeExpression>();
-        KU_ASSERT(nodeOutput != nullptr);
+        RYU_ASSERT(nodeOutput != nullptr);
         planner->getCardinliatyEstimatorUnsafe().init(*nodeOutput);
         auto scanPlan = planner->getNodePropertyScanPlan(*nodeOutput);
         if (!scanPlan.isEmpty()) {
@@ -415,7 +415,7 @@ static void getLogicalPlan(Planner* planner, const BoundReadingClause& readingCl
         }
     }
     auto relOutput = bindData->output[0]->ptrCast<RelExpression>();
-    KU_ASSERT(relOutput != nullptr);
+    RYU_ASSERT(relOutput != nullptr);
     auto scanPlan = LogicalPlan();
     auto boundNode = relOutput->getSrcNode();
     auto nbrNode = relOutput->getDstNode();

diff --git a/extension/algo/src/function/strongly_connected_components_kosaraju.cpp b/extension/algo/src/function/strongly_connected_components_kosaraju.cpp
@@ -67,12 +67,12 @@ class KosarajuVisitedOrder {
     }
 
     void push(offset_t offset) {
-        KU_ASSERT(curData);
+        RYU_ASSERT(curData);
         curData[size_++] = offset;
     }
 
     offset_t pop() {
-        KU_ASSERT(curData && size_ > 0);
+        RYU_ASSERT(curData && size_ > 0);
         size_--;
         return curData[size_];
     }
@@ -89,12 +89,12 @@ class Kosaraju {
 public:
     Kosaraju(Graph* graph, KosarajuVisitedState& visitedState, KosarajuVisitedOrder& visitedOrder)
         : graph{graph}, visitedState{visitedState}, visitedOrder{visitedOrder} {
-        KU_ASSERT(graph->getNodeTableIDs().size() == 1);
+        RYU_ASSERT(graph->getNodeTableIDs().size() == 1);
         nodeTableID = graph->getNodeTableIDs()[0];
         auto nbrInfos = graph->getRelInfos(nodeTableID);
-        KU_ASSERT(nbrInfos.size() == 1);
+        RYU_ASSERT(nbrInfos.size() == 1);
         auto nbrInfo = nbrInfos[0];
-        KU_ASSERT(nbrInfo.srcTableID == nbrInfo.dstTableID);
+        RYU_ASSERT(nbrInfo.srcTableID == nbrInfo.dstTableID);
         scanState = graph->prepareRelScan(*nbrInfo.relGroupEntry, nbrInfo.relTableID,
             nbrInfo.dstTableID, {});
     }
@@ -112,7 +112,7 @@ class Kosaraju {
             if (visitedState.visited(i)) { // Skip visited nodes
                 continue;
             }
-            KU_ASSERT(toProcess.empty());
+            RYU_ASSERT(toProcess.empty());
             toProcess.push_back(i);
             forwardDFS(toProcess);
             // Update fwd progress
@@ -125,7 +125,7 @@ class Kosaraju {
             }
             auto offset = visitedOrder.pop();
             if (!visitedState.componentIDSet(offset)) {
-                KU_ASSERT(toProcess.empty());
+                RYU_ASSERT(toProcess.empty());
                 toProcess.push_back(offset);
                 backwardsDFS(offset, toProcess);
                 // Update bwd progress
@@ -226,7 +226,7 @@ static offset_t tableFunc(const TableFuncInput& input, TableFuncOutput&) {
     auto sharedState = input.sharedState->ptrCast<GDSFuncSharedState>();
     auto mm = MemoryManager::Get(*clientContext);
     auto graph = sharedState->graph.get();
-    KU_ASSERT(graph->getNodeTableIDs().size() == 1);
+    RYU_ASSERT(graph->getNodeTableIDs().size() == 1);
     auto tableID = graph->getNodeTableIDs()[0];
     auto nodeMask = sharedState->getGraphNodeMaskMap();
     if (nodeMask) {

diff --git a/extension/algo/src/include/function/component_ids.h b/extension/algo/src/include/function/component_ids.h
@@ -13,11 +13,11 @@ struct OffsetManager {
 
     void pinTableID(common::table_id_t tableID) { curOffset = getStartOffset(tableID); }
     common::offset_t getStartOffset(common::table_id_t tableID) const {
-        KU_ASSERT(tableIDToStartOffset.contains(tableID));
+        RYU_ASSERT(tableIDToStartOffset.contains(tableID));
         return tableIDToStartOffset.at(tableID);
     }
     common::offset_t getCurrentOffset() const {
-        KU_ASSERT(curOffset != common::INVALID_OFFSET);
+        RYU_ASSERT(curOffset != common::INVALID_OFFSET);
         return curOffset;
     }
 
@@ -34,12 +34,12 @@ class ComponentIDs {
     void pinTableID(common::table_id_t tableID) { curData = denseObjects.getData(tableID); }
 
     void setComponentID(common::offset_t offset, common::offset_t componentID) {
-        KU_ASSERT(curData != nullptr);
+        RYU_ASSERT(curData != nullptr);
         curData[offset] = componentID;
     }
 
     common::offset_t getComponentID(common::offset_t offset) const {
-        KU_ASSERT(curData != nullptr);
+        RYU_ASSERT(curData != nullptr);
         return curData[offset];
     }
     bool hasValidComponentID(common::offset_t offset) const {

diff --git a/extension/azure/src/function/azure_scan.cpp b/extension/azure/src/function/azure_scan.cpp
@@ -26,7 +26,7 @@ static std::unique_ptr<TableFuncBindData> bindFunc(main::ClientContext* context,
             returnColumnNames.push_back(name);
         }
     }
-    KU_ASSERT(returnTypes.size() == returnColumnNames.size());
+    RYU_ASSERT(returnTypes.size() == returnColumnNames.size());
     returnColumnNames =
         TableFunction::extractYieldVariables(returnColumnNames, input->yieldVariables);
     auto columns = input->binder->createVariables(returnColumnNames, returnTypes);

diff --git a/extension/delta/src/function/delta_scan.cpp b/extension/delta/src/function/delta_scan.cpp
@@ -27,7 +27,7 @@ static std::unique_ptr<TableFuncBindData> bindFunc(main::ClientContext* context,
             returnColumnNames.push_back(name);
         }
     }
-    KU_ASSERT(returnTypes.size() == returnColumnNames.size());
+    RYU_ASSERT(returnTypes.size() == returnColumnNames.size());
     returnColumnNames =
         TableFunction::extractYieldVariables(returnColumnNames, input->yieldVariables);
     auto columns = input->binder->createVariables(returnColumnNames, returnTypes);

diff --git a/extension/duckdb/src/catalog/duckdb_table_catalog_entry.cpp b/extension/duckdb/src/catalog/duckdb_table_catalog_entry.cpp
@@ -22,7 +22,7 @@ std::unique_ptr<TableCatalogEntry> DuckDBTableCatalogEntry::copy() const {
 
 std::unique_ptr<binder::BoundExtraCreateCatalogEntryInfo>
 DuckDBTableCatalogEntry::getBoundExtraCreateInfo(transaction::Transaction*) const {
-    KU_UNREACHABLE;
+    RYU_UNREACHABLE;
 }
 
 } // namespace catalog

diff --git a/extension/duckdb/src/connector/connector_factory.cpp b/extension/duckdb/src/connector/connector_factory.cpp
@@ -28,7 +28,7 @@ std::unique_ptr<DuckDBConnector> DuckDBConnectorFactory::getDuckDBConnector(
     case DuckDBConnectionType::S3:
         return std::make_unique<S3DuckDBConnector>();
     default:
-        KU_UNREACHABLE;
+        RYU_UNREACHABLE;
     }
 }
 

diff --git a/extension/duckdb/src/connector/duckdb_connector.cpp b/extension/duckdb/src/connector/duckdb_connector.cpp
@@ -5,7 +5,7 @@ namespace duckdb_extension {
 
 std::unique_ptr<duckdb::MaterializedQueryResult> DuckDBConnector::executeQuery(
     std::string query) const {
-    KU_ASSERT(instance != nullptr && connection != nullptr);
+    RYU_ASSERT(instance != nullptr && connection != nullptr);
     auto result = connection->Query(query);
     if (result->HasError()) {
         throw common::Exception{result->GetError()};

diff --git a/extension/duckdb/src/connector/duckdb_result_converter.cpp b/extension/duckdb/src/connector/duckdb_result_converter.cpp
@@ -72,7 +72,7 @@ void convertDuckDBVectorToVector<list_entry_t>(duckdb::Vector& duckDBVector, Val
         }
     } break;
     default:
-        KU_UNREACHABLE;
+        RYU_UNREACHABLE;
     }
 
     ListVector::resizeDataVector(&result, numValuesInDataVec);
@@ -123,8 +123,8 @@ void DuckDBResultConverter::convertDuckDBResultToVector(duckdb::DataChunk& duckD
         if (columnSkips && columnSkips.value()[i]) {
             continue;
         }
-        KU_ASSERT(duckDBResult.data[duckdbResultColIdx].GetVectorType() ==
-                  duckdb::VectorType::FLAT_VECTOR);
+        RYU_ASSERT(duckDBResult.data[duckdbResultColIdx].GetVectorType() ==
+                   duckdb::VectorType::FLAT_VECTOR);
         conversionFunctions[i](duckDBResult.data[duckdbResultColIdx],
             result.getValueVectorMutable(i), result.state->getSelVector().getSelSize());
         duckdbResultColIdx++;

diff --git a/extension/duckdb/src/connector/duckdb_secret_manager.cpp b/extension/duckdb/src/connector/duckdb_secret_manager.cpp
@@ -17,7 +17,7 @@ static std::string getDuckDBExtensionOptions(httpfs_extension::S3AuthParams ryuO
 
 std::string DuckDBSecretManager::getRemoteS3FSSecret(main::ClientContext* context,
     const httpfs_extension::S3FileSystemConfig& config) {
-    KU_ASSERT(config.fsName == "S3" || config.fsName == "GCS");
+    RYU_ASSERT(config.fsName == "S3" || config.fsName == "GCS");
     std::string templateQuery = R"(CREATE SECRET {}_secret (
         {}
         TYPE {}

diff --git a/extension/fts/src/catalog/fts_index_catalog_entry.cpp b/extension/fts/src/catalog/fts_index_catalog_entry.cpp
@@ -39,7 +39,7 @@ std::string FTSIndexAuxInfo::getStopWordsName(const common::FileScanInfo& export
         }
     } break;
     default:
-        KU_UNREACHABLE;
+        RYU_UNREACHABLE;
     }
     return stopWordsName;
 }

diff --git a/extension/fts/src/function/create_fts_index.cpp b/extension/fts/src/function/create_fts_index.cpp
@@ -129,7 +129,7 @@ static std::string createStopWordsTable(const ClientContext& context,
         query += stringFormat("COPY `{}` FROM '{}';", info.tableName, info.stopWords);
     } break;
     default:
-        KU_UNREACHABLE;
+        RYU_UNREACHABLE;
     }
     return query;
 }

diff --git a/extension/fts/src/function/fts_index_utils.cpp b/extension/fts/src/function/fts_index_utils.cpp
@@ -30,7 +30,7 @@ void FTSIndexUtils::validateIndexExistence(const main::ClientContext& context,
         }
     } break;
     default: {
-        KU_UNREACHABLE;
+        RYU_UNREACHABLE;
     }
     }
 }

diff --git a/extension/fts/src/function/query_fts_index.cpp b/extension/fts/src/function/query_fts_index.cpp
@@ -46,8 +46,8 @@ struct QFTSSharedState : public GDSFuncSharedState {
 
     virtual void addDocScore(std::vector<ValueVector*> vectors,
         processor::FactorizedTable& localTable, DocScore docScore) {
-        KU_ASSERT(vectors[0]->dataType.getLogicalTypeID() == LogicalTypeID::INTERNAL_ID);
-        KU_ASSERT(vectors[1]->dataType.getLogicalTypeID() == LogicalTypeID::DOUBLE);
+        RYU_ASSERT(vectors[0]->dataType.getLogicalTypeID() == LogicalTypeID::INTERNAL_ID);
+        RYU_ASSERT(vectors[1]->dataType.getLogicalTypeID() == LogicalTypeID::DOUBLE);
         vectors[0]->setValue(0, internalID_t{(common::offset_t)docScore.offset, outputTableID});
         vectors[1]->setValue(0, docScore.score);
         localTable.append(vectors);
@@ -137,7 +137,7 @@ struct QFTSEdgeCompute final : EdgeCompute {
 
     std::vector<nodeID_t> edgeCompute(nodeID_t boundNodeID, graph::NbrScanState::Chunk& resultChunk,
         bool) override {
-        KU_ASSERT(dfs.contains(boundNodeID.offset));
+        RYU_ASSERT(dfs.contains(boundNodeID.offset));
         auto df = dfs.at(boundNodeID.offset);
         std::vector<nodeID_t> activeNodes;
         resultChunk.forEach([&](auto neighbors, auto propertyVectors, auto i) {
@@ -473,7 +473,7 @@ static std::unique_ptr<TableFuncBindData> bindFunc(main::ClientContext* context,
     auto nodeTable =
         StorageManager::Get(*context)->getTable(ftsIndexEntry->getTableID())->ptrCast<NodeTable>();
     auto index = nodeTable->getIndex(indexName);
-    KU_ASSERT(index.has_value());
+    RYU_ASSERT(index.has_value());
     auto& ftsIndex = index.value()->cast<FTSIndex>();
     auto& ftsStorageInfo = ftsIndex.getStorageInfo().constCast<FTSStorageInfo>();
     auto bindData = std::make_unique<QueryFTSBindData>(std::move(columns), std::move(graphEntry),
@@ -493,7 +493,7 @@ static void getLogicalPlan(Planner* planner, const BoundReadingClause& readingCl
     planner->planReadOp(std::move(op), predicates, plan);
 
     auto nodeOutput = bindData->output[0]->ptrCast<NodeExpression>();
-    KU_ASSERT(nodeOutput != nullptr);
+    RYU_ASSERT(nodeOutput != nullptr);
     planner->getCardinliatyEstimatorUnsafe().init(*nodeOutput);
     auto scanPlan = planner->getNodePropertyScanPlan(*nodeOutput);
     if (scanPlan.isEmpty()) {

diff --git a/extension/fts/src/function/stem.cpp b/extension/fts/src/function/stem.cpp
@@ -99,7 +99,7 @@ void StemStaticStemmer::operation(common::ku_string_t& word, common::ku_string_t
     common::ku_string_t& result, common::ValueVector& /*leftValueVector*/,
     common::ValueVector& /*rightValueVector*/, common::ValueVector& resultVector, void* dataPtr) {
     auto stemBindData = reinterpret_cast<StemBindData*>(dataPtr);
-    KU_ASSERT(stemBindData->sbStemmer != nullptr);
+    RYU_ASSERT(stemBindData->sbStemmer != nullptr);
     auto stemData = sb_stemmer_stem(stemBindData->sbStemmer,
         reinterpret_cast<const sb_symbol*>(word.getData()), word.len);
     common::StringVector::addString(&resultVector, result, reinterpret_cast<const char*>(stemData),

diff --git a/extension/fts/src/include/function/query_fts_bind_data.h b/extension/fts/src/include/function/query_fts_bind_data.h
@@ -46,7 +46,7 @@ struct QueryFTSBindData final : public function::GDSBindData {
           outputTableID{output[0]->constCast<binder::NodeExpression>().getTableIDs()[0]},
           numDocs{numDocs}, avgDocLen{avgDocLen} {
         auto& nodeExpr = output[0]->constCast<binder::NodeExpression>();
-        KU_ASSERT(nodeExpr.getNumEntries() == 1);
+        RYU_ASSERT(nodeExpr.getNumEntries() == 1);
         outputTableID = nodeExpr.getEntry(0)->getTableID();
         this->optionalParams = std::move(optionalParams);
     }

diff --git a/extension/fts/src/index/fts_index.cpp b/extension/fts/src/index/fts_index.cpp
@@ -225,7 +225,7 @@ void FTSIndex::finalize(main::ClientContext* context) {
 }
 
 void FTSIndex::checkpoint(main::ClientContext* context, storage::PageAllocator& pageAllocator) {
-    KU_ASSERT(!context->isInMemory());
+    RYU_ASSERT(!context->isInMemory());
     auto catalog = catalog::Catalog::Get(*context);
     internalTableInfo.docTable->checkpoint(context,
         catalog->getTableCatalogEntry(&DUMMY_CHECKPOINT_TRANSACTION,

diff --git a/extension/fts/src/main/fts_extension.cpp b/extension/fts/src/main/fts_extension.cpp
@@ -25,7 +25,7 @@ static void initFTSEntries(main::ClientContext* context, catalog::Catalog& catal
             auto& nodeTable =
                 storageManager->getTable(indexEntry->getTableID())->cast<storage::NodeTable>();
             auto optionalIndex = nodeTable.getIndexHolder(indexEntry->getIndexName());
-            KU_ASSERT_UNCONDITIONAL(
+            RYU_ASSERT_UNCONDITIONAL(
                 optionalIndex.has_value() && !optionalIndex.value().get().isLoaded());
             auto& unloadedIndex = optionalIndex.value().get();
             unloadedIndex.load(context, storageManager);

diff --git a/extension/httpfs/src/http_config.cpp b/extension/httpfs/src/http_config.cpp
@@ -7,7 +7,7 @@ namespace ryu {
 namespace httpfs_extension {
 
 HTTPConfig::HTTPConfig(main::ClientContext* context) {
-    KU_ASSERT(context != nullptr);
+    RYU_ASSERT(context != nullptr);
     cacheFile =
         context->getCurrentSetting(HTTPCacheFileConfig::HTTP_CACHE_FILE_OPTION).getValue<bool>();
 }

diff --git a/extension/httpfs/src/httpfs.cpp b/extension/httpfs/src/httpfs.cpp
@@ -190,8 +190,8 @@ void HTTPFileSystem::readFromFile(common::FileInfo& fileInfo, void* buffer, uint
     while (numBytesToRead > 0) {
         auto buffer_read_len = std::min<uint64_t>(httpFileInfo.availableBuffer, numBytesToRead);
         if (buffer_read_len > 0) {
-            KU_ASSERT(httpFileInfo.bufferStartPos + httpFileInfo.bufferIdx + buffer_read_len <=
-                      httpFileInfo.bufferEndPos);
+            RYU_ASSERT(httpFileInfo.bufferStartPos + httpFileInfo.bufferIdx + buffer_read_len <=
+                       httpFileInfo.bufferEndPos);
             memcpy((char*)buffer + bufferOffset,
                 httpFileInfo.readBuffer.get() + httpFileInfo.bufferIdx, buffer_read_len);
 

diff --git a/extension/httpfs/src/s3fs.cpp b/extension/httpfs/src/s3fs.cpp
@@ -42,7 +42,7 @@ void S3FileInfo::initialize(main::ClientContext* context) {
         auto maxNumParts = uploadParams.maxNumPartsPerFile;
         auto requiredPartSize = uploadParams.maxFileSize / maxNumParts;
         partSize = std::max<uint64_t>(AWS_MINIMUM_PART_SIZE, requiredPartSize);
-        KU_ASSERT(partSize * maxNumParts >= uploadParams.maxFileSize);
+        RYU_ASSERT(partSize * maxNumParts >= uploadParams.maxFileSize);
         multipartUploadID = s3FS->initializeMultiPartUpload(this);
     }
 }

diff --git a/extension/iceberg/src/function/iceberg_bindfunc.cpp b/extension/iceberg/src/function/iceberg_bindfunc.cpp
@@ -69,7 +69,7 @@ std::unique_ptr<TableFuncBindData> bindFuncHelper(main::ClientContext* context,
             returnColumnNames.push_back(name);
         }
     }
-    KU_ASSERT(returnTypes.size() == returnColumnNames.size());
+    RYU_ASSERT(returnTypes.size() == returnColumnNames.size());
     returnColumnNames =
         TableFunction::extractYieldVariables(returnColumnNames, input->yieldVariables);
     auto columns = input->binder->createVariables(returnColumnNames, returnTypes);

diff --git a/extension/json/src/functions/creation_functions/json_object.cpp b/extension/json/src/functions/creation_functions/json_object.cpp
@@ -13,7 +13,7 @@ using namespace common;
 static void execFunc(const std::vector<std::shared_ptr<common::ValueVector>>& parameters,
     const std::vector<common::SelectionVector*>& parameterSelVectors, common::ValueVector& result,
     common::SelectionVector* resultSelVector, void* /*dataPtr*/) {
-    KU_ASSERT(parameters.size() % 2 == 0);
+    RYU_ASSERT(parameters.size() % 2 == 0);
     result.resetAuxiliaryBuffer();
     for (auto i = 0u; i < resultSelVector->getSelSize(); ++i) {
         auto resultPos = (*resultSelVector)[i];

diff --git a/extension/json/src/functions/creation_functions/to_json.cpp b/extension/json/src/functions/creation_functions/to_json.cpp
@@ -12,7 +12,7 @@ using namespace common;
 void ToJsonFunction::execFunc(const std::vector<std::shared_ptr<common::ValueVector>>& parameters,
     const std::vector<common::SelectionVector*>& parameterSelVectors, common::ValueVector& result,
     common::SelectionVector* resultSelVector, void* /*dataPtr*/) {
-    KU_ASSERT(parameters.size() == 1);
+    RYU_ASSERT(parameters.size() == 1);
     result.resetAuxiliaryBuffer();
     for (auto i = 0u; i < resultSelVector->getSelSize(); ++i) {
         auto inputPos = (*parameterSelVectors[0])[i];