upsert/delete/tableSinkSettings new parameters cnt

ydb-platform · Jan 20, 2025 · 7aba58f · 7aba58f
1 parent 481bf48
commit 7aba58f
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/ydb/core/kqp/host/kqp_type_ann.cpp b/ydb/core/kqp/host/kqp_type_ann.cpp
@@ -609,7 +609,7 @@ TStatus AnnotateKeyTuple(const TExprNode::TPtr& node, TExprContext& ctx) {
 TStatus AnnotateUpsertRows(const TExprNode::TPtr& node, TExprContext& ctx, const TString& cluster,
     const TKikimrTablesData& tablesData)
 {
-    if (!EnsureMinArgsCount(*node, 3, ctx)) {
+    if (!EnsureMinArgsCount(*node, 4, ctx)) {
         return TStatus::Error;
     }
 
@@ -865,7 +865,7 @@ TStatus AnnotateUpdateRows(const TExprNode::TPtr& node, TExprContext& ctx, const
 TStatus AnnotateDeleteRows(const TExprNode::TPtr& node, TExprContext& ctx, const TString& cluster,
     const TKikimrTablesData& tablesData)
 {
-    if (!EnsureMaxArgsCount(*node, 4, ctx) && !EnsureMinArgsCount(*node, 2, ctx)) {
+    if (!EnsureMaxArgsCount(*node, 4, ctx) && !EnsureMinArgsCount(*node, 3, ctx)) {
         return TStatus::Error;
     }
 
@@ -1851,7 +1851,7 @@ TStatus AnnotateKqpSinkEffect(const TExprNode::TPtr& node, TExprContext& ctx) {
 }
 
 TStatus AnnotateTableSinkSettings(const TExprNode::TPtr& input, TExprContext& ctx) {
-    if (!EnsureMinMaxArgsCount(*input, 5, 7, ctx)) {
+    if (!EnsureMinMaxArgsCount(*input, 6, 7, ctx)) {
         return TStatus::Error;
     }
     input->SetTypeAnn(ctx.MakeType<TVoidExprType>());