1+ import time
12import unittest
23from typing import Optional
34
@@ -279,7 +280,7 @@ def __statistics_callback(stats: QueryStatistics):
279280 ).statistics (__statistics_callback )
280281 )
281282 self .assertEqual (1 , len (companies ))
282- self .assertGreater (statistics .duration_in_ms , 0 )
283+ self .assertGreaterEqual (statistics .duration_in_ms , 0 )
283284 number_of_requests = session .number_of_requests
284285 result_etag = statistics .result_etag
285286
@@ -309,6 +310,8 @@ def __statistics_callback(stats: QueryStatistics):
309310 )
310311 value .value .city = "Bydgoszcz"
311312 inner_session .save_changes ()
313+ self .wait_for_indexing (self .store )
314+ time .sleep (1 )
312315
313316 companies = list (
314317 session .advanced .raw_query (
@@ -319,7 +322,9 @@ def __statistics_callback(stats: QueryStatistics):
319322 + "from Companies as c\n "
320323 + "select incl(c)" ,
321324 Company ,
322- ).statistics (__statistics_callback )
325+ )
326+ .statistics (__statistics_callback )
327+ .wait_for_non_stale_results ()
323328 )
324329
325330 self .assertEqual (1 , len (companies ))
@@ -460,6 +465,8 @@ def __include_cmpxch(builder: QueryIncludeBuilder):
460465 value .value .city = "Bydgoszcz"
461466
462467 inner_session .save_changes ()
468+ self .wait_for_indexing (self .store )
469+ time .sleep (0.3 )
463470
464471 companies = list (
465472 session .query (object_type = Company ).statistics (__statistics_callback ).include (__include_cmpxch )
@@ -539,10 +546,12 @@ def __include_cmpxch(builder: QueryIncludeBuilder):
539546 inner_session .save_changes ()
540547
541548 self .wait_for_indexing (self .store )
549+ time .sleep (0.3 )
542550
543551 companies = list (
544552 session .query_index_type (Companies_ByName , Company )
545553 .statistics (__statistics_callback )
554+ .wait_for_non_stale_results ()
546555 .include (__include_cmpxch )
547556 )
548557
0 commit comments