File tree Expand file tree Collapse file tree 1 file changed +25
-0
lines changed
packages/service-library/src/servicelib/rabbitmq/rpc_interfaces/storage Expand file tree Collapse file tree 1 file changed +25
-0
lines changed Original file line number Diff line number Diff line change 1+ from typing import Final
2+
3+ from models_library .api_schemas_storage import STORAGE_RPC_NAMESPACE
4+ from models_library .api_schemas_storage .zipping_tasks import ZipTask
5+ from models_library .rabbitmq_basic_types import RPCMethodName
6+ from pydantic import NonNegativeInt , TypeAdapter
7+
8+ from ... import RabbitMQRPCClient
9+
10+ _DEFAULT_TIMEOUT_S : Final [NonNegativeInt ] = 30
11+
12+ _RPC_METHOD_NAME_ADAPTER = TypeAdapter (RPCMethodName )
13+
14+
15+ async def start_zipping (
16+ rabbitmq_rpc_client : RabbitMQRPCClient , * , paths : list [str ]
17+ ) -> ZipTask :
18+ result = await rabbitmq_rpc_client .request (
19+ STORAGE_RPC_NAMESPACE ,
20+ _RPC_METHOD_NAME_ADAPTER .validate_python ("start_zipping" ),
21+ paths = paths ,
22+ timeout_s = _DEFAULT_TIMEOUT_S ,
23+ )
24+ assert isinstance (result , ZipTask )
25+ return result
You can’t perform that action at this time.
0 commit comments