diff options
author | Alexander Smirnov <alex@ydb.tech> | 2024-11-20 11:14:58 +0000 |
---|---|---|
committer | Alexander Smirnov <alex@ydb.tech> | 2024-11-20 11:14:58 +0000 |
commit | 31773f157bf8164364649b5f470f52dece0a4317 (patch) | |
tree | 33d0f7eef45303ab68cf08ab381ce5e5e36c5240 /yql/essentials/tests/common/test_framework/solomon_runner.py | |
parent | 2c7938962d8689e175574fc1e817c05049f27905 (diff) | |
parent | eff600952d5dfe17942f38f510a8ac2b203bb3a5 (diff) | |
download | ydb-31773f157bf8164364649b5f470f52dece0a4317.tar.gz |
Merge branch 'rightlib' into mergelibs-241120-1113
Diffstat (limited to 'yql/essentials/tests/common/test_framework/solomon_runner.py')
-rw-r--r-- | yql/essentials/tests/common/test_framework/solomon_runner.py | 40 |
1 files changed, 40 insertions, 0 deletions
diff --git a/yql/essentials/tests/common/test_framework/solomon_runner.py b/yql/essentials/tests/common/test_framework/solomon_runner.py new file mode 100644 index 0000000000..de6062a9ec --- /dev/null +++ b/yql/essentials/tests/common/test_framework/solomon_runner.py @@ -0,0 +1,40 @@ +import os +import pytest +import requests + + +class SolomonWrapper(object): + def __init__(self, url, endpoint): + self._url = url + self._endpoint = endpoint + self.table_prefix = "" + + def is_valid(self): + return self._url is not None + + def cleanup(self): + res = requests.post(self._url + "/cleanup") + res.raise_for_status() + + def get_metrics(self): + res = requests.get(self._url + "/metrics?project=my_project&cluster=my_cluster&service=my_service") + res.raise_for_status() + return res.text + + def prepare_program(self, program, program_file, res_dir, lang='sql'): + return program, program_file + + @property + def url(self): + return self._url + + @property + def endpoint(self): + return self._endpoint + + +@pytest.fixture(scope='module') +def solomon(request): + solomon_url = os.environ.get("SOLOMON_URL") + solomon_endpoint = os.environ.get("SOLOMON_ENDPOINT") + return SolomonWrapper(solomon_url, solomon_endpoint) |