2626 DEFAULT_LEGACY_WB_TO_DV2_HTTP_REQUESTS_TIMEOUT_S * 2
2727)
2828
29+ _RPC_METHOD_NAME_ADAPTER : TypeAdapter [RPCMethodName ] = TypeAdapter (RPCMethodName )
30+
2931
3032@log_decorator (_logger , level = logging .DEBUG )
3133async def get_service_status (
3234 rabbitmq_rpc_client : RabbitMQRPCClient , * , node_id : NodeID
3335) -> NodeGetIdle | DynamicServiceGet | NodeGet :
3436 result = await rabbitmq_rpc_client .request (
3537 DYNAMIC_SCHEDULER_RPC_NAMESPACE ,
36- TypeAdapter ( RPCMethodName ) .validate_python ("get_service_status" ),
38+ _RPC_METHOD_NAME_ADAPTER .validate_python ("get_service_status" ),
3739 node_id = node_id ,
3840 timeout_s = _RPC_DEFAULT_TIMEOUT_S ,
3941 )
@@ -49,7 +51,7 @@ async def run_dynamic_service(
4951) -> DynamicServiceGet | NodeGet :
5052 result = await rabbitmq_rpc_client .request (
5153 DYNAMIC_SCHEDULER_RPC_NAMESPACE ,
52- TypeAdapter ( RPCMethodName ) .validate_python ("run_dynamic_service" ),
54+ _RPC_METHOD_NAME_ADAPTER .validate_python ("run_dynamic_service" ),
5355 dynamic_service_start = dynamic_service_start ,
5456 timeout_s = _RPC_DEFAULT_TIMEOUT_S ,
5557 )
@@ -66,7 +68,7 @@ async def stop_dynamic_service(
6668) -> None :
6769 result = await rabbitmq_rpc_client .request (
6870 DYNAMIC_SCHEDULER_RPC_NAMESPACE ,
69- TypeAdapter ( RPCMethodName ) .validate_python ("stop_dynamic_service" ),
71+ _RPC_METHOD_NAME_ADAPTER .validate_python ("stop_dynamic_service" ),
7072 dynamic_service_stop = dynamic_service_stop ,
7173 timeout_s = timeout_s ,
7274 )
0 commit comments