ITQC/pydase
24
0
Fork 0
mirror of https://github.com/tiqi-group/pydase.git synced 2025-04-21 16:50:02 +02:00
Code Issues Packages Projects Releases Wiki Activity

fixes exception emission to web clients

Browse Source
This commit is contained in:
Mose Müller 2023-12-19 11:20:55 +01:00
parent 6630173cec
commit 1a00f37372
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/pydase/server/server.py
View File

@ -255,14 +255,14 @@ class Server:
future_or_task = self._loop.create_task(addin_server.serve()) future_or_task = self._loop.create_task(addin_server.serve())
self.servers[server_name] = future_or_task self.servers[server_name] = future_or_task
if self._enable_web: if self._enable_web:
web_server = WebServer( self._web_server = WebServer(
service=self._service, service=self._service,
host=self._host, host=self._host,
port=self._web_port, port=self._web_port,
data_service_observer=self._observer, data_service_observer=self._observer,
**self._kwargs, **self._kwargs,
) )
future_or_task = self._loop.create_task(web_server.serve()) future_or_task = self._loop.create_task(self._web_server.serve())
self.servers["web"] = future_or_task self.servers["web"] = future_or_task
async def main_loop(self) -> None: async def main_loop(self) -> None:
@ -335,7 +335,7 @@ class Server:
async def emit_exception() -> None: async def emit_exception() -> None:
try: try:
await self._wapi.sio.emit( await self._web_server._sio.emit(
"exception", "exception",
{ {
"data": { "data": {

4
src/pydase/server/web_server/web_server.py
View File

@ -77,8 +77,8 @@ class WebServer:
await self.web_server.serve() await self.web_server.serve()
def _setup_socketio(self) -> None: def _setup_socketio(self) -> None:
self.__sio = SioServerWrapper(self.observer, self.enable_cors, self._loop).sio self._sio = SioServerWrapper(self.observer, self.enable_cors, self._loop).sio
self.__sio_app = socketio.ASGIApp(self.__sio) self.__sio_app = socketio.ASGIApp(self._sio)
def _setup_fastapi_app(self) -> None: def _setup_fastapi_app(self) -> None:
app = FastAPI() app = FastAPI()