Skip to content

Commit 1b81707

Browse files
committed
move rpc name validation out of method @sanderegg
1 parent 6d71d32 commit 1b81707

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

packages/service-library/src/servicelib/rabbitmq/rpc_interfaces/director_v2/computations_tasks.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
# pylint: disable=too-many-arguments
22
import logging
3+
from typing import Final
34

45
from models_library.api_schemas_directorv2 import (
56
DIRECTOR_V2_RPC_NAMESPACE,
@@ -17,6 +18,10 @@
1718

1819
_RPC_METHOD_NAME_ADAPTER: TypeAdapter[RPCMethodName] = TypeAdapter(RPCMethodName)
1920

21+
_GET_COMPUTATION_TASK_LOG_FILE_IDS: Final[RPCMethodName] = (
22+
_RPC_METHOD_NAME_ADAPTER.validate_python("get_computation_task_log_file_ids")
23+
)
24+
2025

2126
@log_decorator(_logger, level=logging.DEBUG)
2227
async def get_computation_task_log_file_ids(
@@ -28,7 +33,7 @@ async def get_computation_task_log_file_ids(
2833
"""
2934
result = await rabbitmq_rpc_client.request(
3035
DIRECTOR_V2_RPC_NAMESPACE,
31-
_RPC_METHOD_NAME_ADAPTER.validate_python("get_computation_task_log_file_ids"),
36+
_GET_COMPUTATION_TASK_LOG_FILE_IDS,
3237
project_id=project_id,
3338
)
3439
assert isinstance(result, list) # nosec

0 commit comments

Comments
 (0)