Matrix/synapse
Matrix/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse synced 2024-09-12 07:05:12 +00:00
Code Issues Projects Releases Packages Wiki Activity

A bit more paramspec

Browse source
This commit is contained in:
David Robertson 2022-08-21 23:28:48 +01:00
parent dd70d11373
commit 9b6764b2ef
No known key found for this signature in database
GPG key ID: 903ECE108A39DEDD
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
tests/server.py
View file

@ -100,6 +100,7 @@ logger = logging.getLogger(__name__)
# the type of thing that can be passed into `make_request` in the headers list
CustomHeaderType = Tuple[Union[str, bytes], Union[str, bytes]]
P = ParamSpec("P")
R = TypeVar("R")
class TimedOutException(Exception):
@ -559,7 +560,7 @@ def _make_test_homeserver_synchronous(server: HomeServer) -> None:
for database in server.get_datastores().databases:
pool = database._db_pool
def runWithConnection(func, *args, **kwargs):
def runWithConnection(func: Callable[P, R], *args: P.args, **kwargs: P.kwargs) -> "Deferred[R]":
return threads.deferToThreadPool(
pool._reactor,
pool.threadpool,
@ -569,7 +570,7 @@ def _make_test_homeserver_synchronous(server: HomeServer) -> None:
**kwargs,
)
def runInteraction(interaction, *args, **kwargs):
def runInteraction(interaction: Callable[P, R], *args: P.args, **kwargs: P.kwargs) -> "Deferred[R]":
return threads.deferToThreadPool(
pool._reactor,
pool.threadpool,