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

removes ForkingServer rpyc configuration

Browse Source
This commit is contained in:
Mose Müller 2023-12-19 13:07:25 +01:00
parent 232eb53249
commit 8214faf5cb
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -8,7 +8,7 @@ from pathlib import Path
from types import FrameType from types import FrameType
from typing import Any, Protocol, TypedDict from typing import Any, Protocol, TypedDict
from rpyc import ForkingServer, ThreadedServer # type: ignore[import-untyped] from rpyc import ThreadedServer # type: ignore[import-untyped]
from uvicorn.server import HANDLED_SIGNALS from uvicorn.server import HANDLED_SIGNALS
from pydase import DataService from pydase import DataService
@ -156,7 +156,6 @@ class Server:
enable_rpc: bool = True, enable_rpc: bool = True,
enable_web: bool = True, enable_web: bool = True,
filename: str | Path | None = None, filename: str | Path | None = None,
use_forking_server: bool = False,
additional_servers: list[AdditionalServer] | None = None, additional_servers: list[AdditionalServer] | None = None,
**kwargs: Any, **kwargs: Any,
) -> None: ) -> None:
@ -170,7 +169,6 @@ class Server:
self._enable_web = enable_web self._enable_web = enable_web
self._kwargs = kwargs self._kwargs = kwargs
self._loop: asyncio.AbstractEventLoop self._loop: asyncio.AbstractEventLoop
self._rpc_server_type = ForkingServer if use_forking_server else ThreadedServer
self._additional_servers = additional_servers self._additional_servers = additional_servers
self.should_exit = False self.should_exit = False
self.servers: dict[str, asyncio.Future[Any]] = {} self.servers: dict[str, asyncio.Future[Any]] = {}
@ -225,7 +223,7 @@ class Server:
if self._enable_rpc: if self._enable_rpc:
self.executor = ThreadPoolExecutor() self.executor = ThreadPoolExecutor()
self._rpc_server = self._rpc_server_type( self._rpc_server = ThreadedServer(
self._service, self._service,
port=self._rpc_port, port=self._rpc_port,
protocol_config={ protocol_config={