async def notify_startup(self):
        """Notify the ASGI app that the server has started."""
        self._logger.debug("Notifying ASGI app of startup.")

        # Initialize signals and queues
        if not self.lifespan_receive_queue:
            self.lifespan_receive_queue = Queue()
        if not self.lifespan_startup_event:
            self.lifespan_startup_event = Event()
        if not self.lifespan_shutdown_event:
            self.lifespan_shutdown_event = Event()

        startup_event = {"type": "lifespan.startup"}
        await self.lifespan_receive_queue.put(startup_event)
        task = asyncio.create_task(self._lifespan_main())  # NOQA
        await self.lifespan_startup_event.wait()
        return self._startup_succeeded
Notify the ASGI app that the server has started.
Solutions/CyberArkAudit/Data Connectors/.python_packages/lib/site-packages/azure/functions/_http_asgi.py