Skip to content

Commit 80c6a49

Browse files
committed
add params
1 parent 15b3af9 commit 80c6a49

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

ydb/core/kqp/ut/opt/kqp_returning_ut.cpp

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,13 @@ Y_UNIT_TEST(ReturningTwice) {
9090
SELECT eta, hashed_key, queue_name, task_id FROM $to_move;
9191
)");
9292

93-
auto result = session.ExecuteDataQuery(query, TTxControl::BeginTx().CommitTx()).GetValueSync();
93+
auto params = TParamsBuilder()
94+
.AddParam("$eta").Timestamp(TInstant::Zero()).Build()
95+
.AddParam("$expiration_ts").Timestamp(TInstant::Zero()).Build()
96+
.AddParam("$limit").Int32(1).Build()
97+
.Build();
98+
99+
auto result = session.ExecuteDataQuery(query, TTxControl::BeginTx().CommitTx(), params).GetValueSync();
94100
UNIT_ASSERT(result.IsSuccess());
95101

96102
//CompareYson(R"([[1]])", FormatResultSetYson(result.GetResultSet(0)));

0 commit comments

Comments
 (0)