diff --git a/ydb/library/yql/dq/type_ann/dq_type_ann.cpp b/ydb/library/yql/dq/type_ann/dq_type_ann.cpp
index 258dad5297f7..465ee8eaa7ac 100644
--- a/ydb/library/yql/dq/type_ann/dq_type_ann.cpp
+++ b/ydb/library/yql/dq/type_ann/dq_type_ann.cpp
@@ -5,6 +5,7 @@
 #include <yql/essentials/core/type_ann/type_ann_core.h>
 #include <yql/essentials/core/yql_type_helpers.h>
 #include <yql/essentials/utils/log/log.h>
+#include <ydb/library/yql/providers/dq/expr_nodes/dqs_expr_nodes.h>
 
 #include <yql/essentials/providers/common/provider/yql_provider.h>
 
@@ -615,6 +616,18 @@ TStatus AnnotateDqConnection(const TExprNode::TPtr& input, TExprContext& ctx) {
     return TStatus::Ok;
 }
 
+TStatus AnnotateTDqSourceWrapBase(const TExprNode::TPtr& input, TExprContext& /*ctx*/) {
+    [[maybe_unused]]
+    auto dqLookupSourceWrap = TDqSourceWrapBase(input);
+    return TStatus::Ok;
+}
+
+TStatus AnnotateTDqLookupSourceWrap(const TExprNode::TPtr& input, TExprContext& ctx) {
+    [[maybe_unused]]
+    auto dqLookupSourceWrap = TDqLookupSourceWrap(input).Input();
+    return AnnotateTDqSourceWrapBase(input, ctx);
+}
+
 TStatus AnnotateDqCnStreamLookup(const TExprNode::TPtr& input, TExprContext& ctx) {
     auto cnStreamLookup = TDqCnStreamLookup(input);
     auto leftInputType = GetDqConnectionType(TDqConnection(input), ctx);