openr/py/openr/cli/commands/fib.py [434:451]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    def run(self, *args, **kwargs) -> int:
        """
        Override run method to create py3 client for streaming.
        """

        async def _wrapper() -> int:
            client_type = ClientType.THRIFT_ROCKET_CLIENT_TYPE
            async with get_openr_ctrl_cpp_client(
                self.host, self.cli_opts, client_type=client_type
            ) as client:
                await self._run(client, *args, **kwargs)
            return 0

        return asyncio.run(_wrapper())

    async def _run(
        self,
        client: OpenrCtrlCppClient,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



openr/py/openr/cli/commands/kvstore.py [907:924]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    def run(self, *args, **kwargs) -> int:
        """
        Override run method to create py3 client for streaming.
        """

        async def _wrapper() -> int:
            client_type = ClientType.THRIFT_ROCKET_CLIENT_TYPE
            async with get_openr_ctrl_cpp_client(
                self.host, self.cli_opts, client_type=client_type
            ) as client:
                await self._run(client, *args, **kwargs)
            return 0

        return asyncio.run(_wrapper())

    async def _run(
        self,
        client: OpenrCtrlCppClient,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -