fill filter predicate to fix pq tests (#10688)

ydb-platform · Oct 22, 2024 · 2b0ccd7 · 2b0ccd7
1 parent 8b24d79
commit 2b0ccd7
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/ydb/library/yql/providers/pq/provider/yql_pq_dq_integration.cpp b/ydb/library/yql/providers/pq/provider/yql_pq_dq_integration.cpp
@@ -129,6 +129,16 @@ class TPqDqIntegration: public TDqIntegrationBase {
                 columns = ctx.NewList(pos, std::move(cols));
             }
 
+            auto row = Build<TCoArgument>(ctx, read->Pos())
+                .Name("row")
+                .Done();
+            auto emptyPredicate = Build<TCoLambda>(ctx, read->Pos())
+                .Args({row})
+                .Body<TCoBool>()
+                    .Literal().Build("true")
+                    .Build()
+                .Done().Ptr();
+
             return Build<TDqSourceWrap>(ctx, read->Pos())
                 .Input<TDqPqTopicSource>()
                     .World(pqReadTopic.World())
@@ -138,6 +148,7 @@ class TPqDqIntegration: public TDqIntegrationBase {
                     .Token<TCoSecureParam>()
                         .Name().Build(token)
                         .Build()
+                    .FilterPredicate(emptyPredicate)
                     .Build()
                 .RowType(ExpandType(pqReadTopic.Pos(), *rowType, ctx))
                 .DataSource(pqReadTopic.DataSource().Cast<TCoDataSource>())