@@ -133,21 +133,22 @@ Y_UNIT_TEST_SUITE(KqpWorkloadServiceTables) {
133
133
Y_UNIT_TEST (TestLeaseExpiration) {
134
134
auto ydb = TYdbSetupSettings ()
135
135
.ConcurrentQueryLimit (1 )
136
+ .QueryCancelAfter (TDuration::Zero ())
136
137
.Create ();
137
138
138
139
// Create tables
139
- TSampleQueries::TSelect42::CheckResult (ydb->ExecuteQuery (TSampleQueries::TSelect42::Query));
140
+ auto hangingRequest = ydb->ExecuteQueryAsync (TSampleQueries::TSelect42::Query, TQueryRunnerSettings ().HangUpDuringExecution (true ));
141
+ ydb->WaitQueryExecution (hangingRequest);
140
142
141
- const TDuration leaseDuration = TDuration::Seconds (10 );
142
- StartRequest (ydb, " test_session" , leaseDuration);
143
- DelayRequest (ydb, " test_session" , leaseDuration);
144
- CheckPoolDescription (ydb, 1 , 1 , leaseDuration);
143
+ auto delayedRequest = ydb->ExecuteQueryAsync (TSampleQueries::TSelect42::Query, TQueryRunnerSettings ().ExecutionExpected (false ));
144
+ ydb->WaitPoolState ({.DelayedRequests = 1 , .RunningRequests = 1 });
145
145
146
146
ydb->StopWorkloadService ();
147
147
ydb->WaitPoolHandlersCount (0 );
148
148
149
149
// Check that lease expired
150
- Sleep (leaseDuration + TDuration::Seconds (20 ));
150
+ const TDuration leaseDuration = TDuration::Seconds (30 ); // Same as pool_handlers_acors.cpp:LEASE_DURATION
151
+ Sleep (leaseDuration + TDuration::Seconds (5 )); // 5s for last pool refresh request
151
152
CheckPoolDescription (ydb, 0 , 0 );
152
153
}
153
154
0 commit comments