Merge 270275c into 3c2e65a

ydb-platform · Dec 23, 2024 · fe432c3 · fe432c3
2 parents 3c2e65a + 270275c
commit fe432c3
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 8 deletions.
diff --git a/.github/scripts/analytics/upload_tests_results.py b/.github/scripts/analytics/upload_tests_results.py
@@ -218,9 +218,9 @@ def main():
             test_results_file, build_type, job_name, job_id, commit, branch, pull, run_timestamp
         )
         result_with_owners = get_codeowners_for_tests(codeowners, results)
-        prepared_for_update_rows = []
+        prepared_for_upload_rows = []
         for index, row in enumerate(result_with_owners):
-            prepared_for_update_rows.append({
+            prepared_for_upload_rows.append({
                 'branch': row['branch'],
                 'build_type': row['build_type'],
                 'commit': row['commit'],
@@ -240,15 +240,19 @@ def main():
                 'test_id': f"{row['pull']}_{row['run_timestamp']}_{index}",
                 'test_name': row['test_name'],
             })
-        print(f'upserting runs: {len(prepared_for_update_rows)} rows')
-        if prepared_for_update_rows:
+        print(f'upserting runs: {len(prepared_for_upload_rows)} rows')
+        if prepared_for_upload_rows:
+            batch_rows_for_upload_size = 1000
             with ydb.SessionPool(driver) as pool:
                 create_tables(pool, test_table_name)
-                bulk_upsert(driver.table_client, full_path,
-                        prepared_for_update_rows)
-                print('tests updated')
+                for start in range(0, len(prepared_for_upload_rows), batch_rows_for_upload_size):
+                    batch_rows_for_upload = prepared_for_upload_rows[start:start + batch_rows_for_upload_size]     
+                    bulk_upsert(driver.table_client, full_path,
+                            batch_rows_for_upload)
+
+            print('tests uploaded')
         else:
-            print('nothing to upsert')
+            print('nothing to upload')
 
 
 

diff --git a/ydb/core/tx/columnshard/columnshard.cpp b/ydb/core/tx/columnshard/columnshard.cpp
@@ -239,6 +239,7 @@ void TColumnShard::Handle(TEvPrivate::TEvPeriodicWakeup::TPtr& ev, const TActorC
         AFL_DEBUG(NKikimrServices::TX_COLUMNSHARD)("event", "TEvPrivate::TEvPeriodicWakeup")("tablet_id", TabletID());
         SendWaitPlanStep(GetOutdatedStep());
 
+
         SendPeriodicStats();
         EnqueueBackgroundActivities();
         ctx.Schedule(PeriodicWakeupActivationPeriod, new TEvPrivate::TEvPeriodicWakeup());