diff --git a/ydb/services/datastreams/datastreams_ut.cpp b/ydb/services/datastreams/datastreams_ut.cpp
index 664300f93e03..64df2d23a0d5 100644
--- a/ydb/services/datastreams/datastreams_ut.cpp
+++ b/ydb/services/datastreams/datastreams_ut.cpp
@@ -376,6 +376,8 @@ Y_UNIT_TEST_SUITE(DataStreams) {
             }
         }
 
+        sleep(1);
+
         auto putUnitsSchemaFound =
             CheckMeteringFile(testServer.MeteringFile.Get(), "/Root/" + streamName, "yds.events.puts.v1",
                           [](const NJson::TJsonValue::TMapType& map) {
@@ -463,6 +465,8 @@ Y_UNIT_TEST_SUITE(DataStreams) {
             }
         }
 
+        sleep(1);
+
         auto storageSchemaFound =
             CheckMeteringFile(testServer.MeteringFile.Get(), "/Root/" + streamName, "yds.storage.reserved.v1",
                             [](const NJson::TJsonValue::TMapType& map) {
@@ -645,6 +649,8 @@ Y_UNIT_TEST_SUITE(DataStreams) {
             UNIT_ASSERT(res.GetValue().IsSuccess());
         }
 
+        sleep(1);
+
         auto storageSchemaFound =
             CheckMeteringFile(testServer.MeteringFile.Get(), "/Root/" + streamName, "yds.storage.reserved.v1",
                             [](const NJson::TJsonValue::TMapType& map) {
@@ -772,6 +778,8 @@ Y_UNIT_TEST_SUITE(DataStreams) {
             UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());
         }
 
+        sleep(1);
+
         auto putUnitsSchemaFound =
             CheckMeteringFile(testServer.MeteringFile.Get(), streamPath, "yds.events.puts.v1",
                           [](const NJson::TJsonValue::TMapType&) {},
@@ -1234,6 +1242,8 @@ Y_UNIT_TEST_SUITE(DataStreams) {
             }
         }
 
+        sleep(1);
+
         CheckMeteringFile(testServer.MeteringFile.Get(), "/Root/" + streamName,
                           "yds.throughput.reserved.v1",
                           [](const NJson::TJsonValue::TMapType& map) {