Create kesuses for rate limiting in YQ

Fill config in kikimr runner

Create coordination nodes

Pass to config

Protos

2 files changed, 7 insertions, 0 deletions

diff --git a/library/python/pytest/plugins/conftests.py b/library/python/pytest/plugins/conftests.py
index 3c855c9c11..2ea36ae4c2 100644
--- a/library/python/pytest/plugins/conftests.py
+++ b/library/python/pytest/plugins/conftests.py
@@ -3,7 +3,10 @@ import importlib
 import sys
 import inspect
 
+import yatest.common as yc
+
 from pytest import hookimpl
+from yatest_lib.ya import Ya
 
 from .fixtures import metrics, links  # noqa
 
@@ -23,6 +26,7 @@ conftest_modules = []
 
 @hookimpl(trylast=True)
 def pytest_load_initial_conftests(early_config, parser, args):
+    yc.runtime._set_ya_config(ya=Ya())
     conftests = filter(lambda name: name.endswith(".conftest"), sys.extra_modules)
 
     def conftest_key(name):
diff --git a/library/python/pytest/plugins/ya.py b/library/python/pytest/plugins/ya.py
index 5b48ab775d..715d24ce5b 100644
--- a/library/python/pytest/plugins/ya.py
+++ b/library/python/pytest/plugins/ya.py
@@ -30,6 +30,7 @@ import _pytest.skipping
 from _pytest.warning_types import PytestUnhandledCoroutineWarning
 
 from yatest_lib import test_splitter
+import yatest.common as yatest_common
 
 try:
     import resource
@@ -283,6 +284,8 @@ def pytest_configure(config):
     if config.option.pdb_on_sigusr1:
         configure_pdb_on_demand()
 
+    yatest_common.runtime._set_ya_config(config=config)
+
     # Dump python backtrace in case of any errors
     faulthandler.enable()
     if hasattr(signal, "SIGQUIT"):