Skip to content

Commit 9a4d7c4

Browse files
author
mpereskokova
committed
YT-23942: GetDeclaredParametersInfo -> GetQueryDeclaredParametersInfo
commit_hash:38ae30b19ea6d75729ce97c028f73326ba29493a
1 parent 686370e commit 9a4d7c4

File tree

4 files changed

+27
-27
lines changed

4 files changed

+27
-27
lines changed

yt/python/yt/wrapper/client_api.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
from .queue_commands import ( # noqa
1616
register_queue_consumer, unregister_queue_consumer, list_queue_consumer_registrations, pull_queue, pull_consumer, pull_queue_consumer,
1717
advance_consumer, advance_queue_consumer, create_queue_producer_session, remove_queue_producer_session, push_queue_producer)
18-
from .query_commands import start_query, run_query, abort_query, alter_query, read_query_result, get_query, get_query_result, get_declared_parameters_info, get_query_tracker_info, list_queries # noqa
18+
from .query_commands import start_query, run_query, abort_query, alter_query, read_query_result, get_query, get_query_result, get_query_declared_parameters_info, get_query_tracker_info, list_queries # noqa
1919
from .run_operation_commands import ( # noqa
2020
run_erase, run_merge, run_sort, run_map_reduce, run_map, run_reduce,
2121
run_join_reduce, run_remote_copy, run_operation)

yt/python/yt/wrapper/client_impl.py

Lines changed: 22 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -991,28 +991,6 @@ def get_current_user(self) -> Optional[DictCurrentUser]:
991991
"""
992992
return client_api.get_current_user(client=self)
993993

994-
def get_declared_parameters_info(
995-
self,
996-
query, engine,
997-
stage=None, settings=None, format=None):
998-
"""
999-
Get parameters DECLAREd in YQL query. Currently supported only for YQL.
1000-
1001-
:param query: text of query to be parsed
1002-
:type query: str
1003-
:param engine: query engine, one of "ql", "yql", "chyt", "spyt".
1004-
:type engine: str
1005-
:param stage: query tracker stage, defaults to "production"
1006-
:type stage: str
1007-
:param settings: a dictionary of settings
1008-
:type settings: dict or None
1009-
1010-
"""
1011-
return client_api.get_declared_parameters_info(
1012-
query, engine,
1013-
client=self,
1014-
stage=stage, settings=settings, format=format)
1015-
1016994
def get_file_from_cache(
1017995
self,
1018996
md5,
@@ -1262,6 +1240,28 @@ def get_query(
12621240
client=self,
12631241
attributes=attributes, stage=stage, format=format)
12641242

1243+
def get_query_declared_parameters_info(
1244+
self,
1245+
query, engine,
1246+
stage=None, settings=None, format=None):
1247+
"""
1248+
Get parameters DECLAREd in YQL query. Currently supported only for YQL.
1249+
1250+
:param query: text of query to be parsed
1251+
:type query: str
1252+
:param engine: query engine, one of "ql", "yql", "chyt", "spyt".
1253+
:type engine: str
1254+
:param stage: query tracker stage, defaults to "production"
1255+
:type stage: str
1256+
:param settings: a dictionary of settings
1257+
:type settings: dict or None
1258+
1259+
"""
1260+
return client_api.get_query_declared_parameters_info(
1261+
query, engine,
1262+
client=self,
1263+
stage=stage, settings=settings, format=format)
1264+
12651265
def get_query_result(
12661266
self,
12671267
query_id,

yt/python/yt/wrapper/query_commands.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -232,7 +232,7 @@ def get_query_tracker_info(attributes=None, stage=None, format=None, client=None
232232
return make_formatted_request("get_query_tracker_info", params=params, format=format, client=client)
233233

234234

235-
def get_declared_parameters_info(query, engine, stage=None, settings=None, format=None, client=None):
235+
def get_query_declared_parameters_info(query, engine, stage=None, settings=None, format=None, client=None):
236236
"""Get parameters DECLAREd in YQL query. Currently supported only for YQL.
237237
238238
:param query: text of query to be parsed
@@ -252,7 +252,7 @@ def get_declared_parameters_info(query, engine, stage=None, settings=None, forma
252252
}
253253
set_param(params, "settings", settings)
254254

255-
return make_formatted_request("get_declared_parameters_info", params=params, format=format, client=client)
255+
return make_formatted_request("get_query_declared_parameters_info", params=params, format=format, client=client)
256256

257257
# Helpers
258258

yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3652,15 +3652,15 @@ message TRspGetQueryTrackerInfo
36523652

36533653
////////////////////////////////////////////////////////////////////////////////
36543654

3655-
message TReqGetDeclaredParametersInfo
3655+
message TReqGetQueryDeclaredParametersInfo
36563656
{
36573657
required string query_tracker_stage = 1;
36583658
required string query = 2;
36593659
required EQueryEngine engine = 3;
36603660
optional bytes settings = 4; // YSON
36613661
}
36623662

3663-
message TRspGetDeclaredParametersInfo
3663+
message TRspGetQueryDeclaredParametersInfo
36643664
{
36653665
required bytes declared_parameters_info = 1; // YSON
36663666
}

0 commit comments

Comments
 (0)