We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent bb31075 commit e9a91dfCopy full SHA for e9a91df
ydb/core/kqp/opt/kqp_opt_build_txs.cpp
@@ -830,6 +830,10 @@ class TKqpBuildTxsTransformer : public TSyncTransformerBase {
830
auto input = stage.Inputs().Item(i);
831
if (auto maybeConn = input.Maybe<TDqConnection>()) {
832
auto conn = maybeConn.Cast();
833
+ if (!conn.Maybe<TDqCnValue>() && !conn.Maybe<TDqCnUnionAll>()) {
834
+ continue;
835
+ }
836
+
837
if (phaseStagesMap.contains(conn.Output().Stage().Raw())) {
838
auto oldArg = stage.Program().Args().Arg(i);
839
auto newArg = Build<TCoArgument>(ctx, stage.Program().Args().Arg(i).Pos())
0 commit comments