jina/peapods/runtimes/asyncio/http/__init__.py
async def async_setup(self):
        """
        The async method setup the runtime.

        Setup the uvicorn server.
        """
        with ImportExtensions(required=True):
            from uvicorn import Config, Server

        class UviServer(Server):
            """The uvicorn server."""

            async def setup(self, sockets=None):
                """
                Setup uvicorn server.

                :param sockets: sockets of server.
                """
                config = self.config
                if not config.loaded:
                    config.load()
                self.lifespan = config.lifespan_class(config)
                self.install_signal_handlers()
                await self.startup(sockets=sockets)
                if self.should_exit:
                    return

            async def serve(self, sockets=None):
                """
                Start the server.

                :param sockets: sockets of server.
                """
                await self.main_loop()
                await self.shutdown(sockets=sockets)

        from .....helper import extend_rest_interface

        self._server = UviServer(
            config=Config(
                app=extend_rest_interface(get_fastapi_app(self.args, self.logger)),
                host=self.args.host,
                port=self.args.port_expose,
                log_level=os.getenv('JINA_LOG_LEVEL', 'error').lower(),
            )
        )
        await self._server.setup()
        self.logger.success(
            f'{self.__class__.__name__} is listening at: {self.args.host}:{self.args.port_expose}'
        )

        The async method setup the runtime.

        Setup the uvicorn server.
        
The async method setup the runtime.
Setup the uvicorn server.
The async method setup the runtime . Setup the uvicorn server .
async def async_setup(self):
        with ImportExtensions(required=True):
            from uvicorn import Config, Server
        class UviServer(Server):
            async def setup(self, sockets=None):
                config = self.config
                if not config.loaded:
                    config.load()
                self.lifespan = config.lifespan_class(config)
                self.install_signal_handlers()
                await self.startup(sockets=sockets)
                if self.should_exit:
                    return
            async def serve(self, sockets=None):
                await self.main_loop()
                await self.shutdown(sockets=sockets)
        from .....helper import extend_rest_interface
        self._server = UviServer(
            config=Config(
                app=extend_rest_interface(get_fastapi_app(self.args, self.logger)),
                host=self.args.host,
                port=self.args.port_expose,
                log_level=os.getenv('JINA_LOG_LEVEL', 'error').lower(),
            )
        )
        await self._server.setup()
        self.logger.success(
            f'{self.__class__.__name__} is listening at: {self.args.host}:{self.args.port_expose}'
        )
async def async_setup ( self ) : with ImportExtensions ( required = True ) : from uvicorn import Config , Server class UviServer ( Server ) : """The uvicorn server.""" async def setup ( self , sockets = None ) : """
                Setup uvicorn server.

                :param sockets: sockets of server.
                """ config = self . config if not config . loaded : config . load ( ) self . lifespan = config . lifespan_class ( config ) self . install_signal_handlers ( ) await self . startup ( sockets = sockets ) if self . should_exit : return async def serve ( self , sockets = None ) : """
                Start the server.

                :param sockets: sockets of server.
                """ await self . main_loop ( ) await self . shutdown ( sockets = sockets ) from . . . . . helper import extend_rest_interface self . _server = UviServer ( config = Config ( app = extend_rest_interface ( get_fastapi_app ( self . args , self . logger ) ) , host = self . args . host , port = self . args . port_expose , log_level = os . getenv ( 'JINA_LOG_LEVEL' , 'error' ) . lower ( ) , ) ) await self . _server . setup ( ) self . logger . success ( f'{self.__class__.__name__} is listening at: {self.args.host}:{self.args.port_expose}' )
The async method setup the runtime.
The async method setup the runtime .
"""
        The async method setup the runtime.

        Setup the uvicorn server.
        """ """The uvicorn server.""" """
                Setup uvicorn server.

                :param sockets: sockets of server.
                """ """
                Start the server.

                :param sockets: sockets of server.
                """
self