diff --git a/aiokdb/__init__.py b/aiokdb/__init__.py index 5b67e1c..67d1db6 100644 --- a/aiokdb/__init__.py +++ b/aiokdb/__init__.py @@ -66,6 +66,7 @@ class Nulls: c: str = " " e: float = float("nan") f: float = float("nan") + uu: uuid.UUID = uuid.UUID("00000000-0000-0000-0000-000000000000") class Infs: diff --git a/aiokdb/server.py b/aiokdb/server.py index 9fa8add..2b6a161 100644 --- a/aiokdb/server.py +++ b/aiokdb/server.py @@ -4,11 +4,17 @@ import logging import os import struct +import sys from functools import partial from typing import Any, Callable, List, Optional, Tuple from aiokdb import KException, KObj, MessageType, TypeEnum, b9, d9, krr, logger +if sys.version_info >= (3, 9): + AsyncioServer = asyncio.Server +else: + AsyncioServer = Any + class CredentialsException(Exception): pass @@ -321,7 +327,7 @@ async def handle_connection( pass -async def start_qserver(port: int, context: ServerContext) -> Any: +async def start_qserver(port: int, context: ServerContext) -> AsyncioServer: logging.info(f"opening KDB-q IPC server on port {port}") server = await asyncio.start_server(partial(handle_connection, context), "", port) await context.start_tasks()