This commit is contained in:
Trinh Anh Ngoc
2023-05-19 12:21:45 +07:00
parent 54ea622c22
commit 404bafbecd
46 changed files with 49 additions and 875 deletions

View File

@@ -9,17 +9,6 @@ class DatabaseExists(Warning): ...
def check_db_management_enabled(method: _CallableT) -> _CallableT: ...
def check_super(passwd: str) -> Literal[True]: ...
def _initialize_db(
id,
db_name: str,
demo: bool,
lang: str,
user_password: str,
login: str = ...,
country_code: str | None = ...,
phone: str | None = ...,
) -> None: ...
def _create_empty_database(name: str) -> None: ...
def exp_create_database(
db_name: str,
demo: bool,
@@ -30,7 +19,6 @@ def exp_create_database(
phone: str | None = ...,
) -> Literal[True]: ...
def exp_duplicate_database(db_original_name: str, db_name: str) -> Literal[True]: ...
def _drop_conn(cr: Cursor, db_name: str) -> None: ...
def exp_drop(db_name: str) -> bool: ...
def exp_dump(db_name: str, format: str) -> str: ...
def dump_db_manifest(cr: Cursor) -> dict[str, Any]: ...

View File

@@ -1,22 +1,17 @@
from typing import Any, Callable, Iterator, TypeVar
from psycopg2 import IntegrityError
from typing import Any, Callable, TypeVar
from ..api import Environment
from ..exceptions import ValidationError
from ..sql_db import Cursor
_CallableT = TypeVar("_CallableT", bound=Callable)
PG_CONCURRENCY_ERRORS_TO_RETRY: tuple[str, str, str]
MAX_TRIES_ON_CONCURRENCY_FAILURE: int
_CallableT = TypeVar("_CallableT", bound=Callable)
def dispatch(method: str, params): ...
def execute_cr(cr: Cursor, uid: int, obj: str, method: str, *args, **kw): ...
def execute_kw(
db: str, uid: int, obj: str, method: str, args, kw: dict | None = ...
): ...
def execute(db: str, uid: int, obj: str, method: str, *args, **kw): ...
def _as_validation_error(env: Environment, exc: IntegrityError) -> ValidationError: ...
def retrying(func: Callable[[], Any], env: Environment): ...
def _traverse_containers(val, type_) -> Iterator: ...

View File

@@ -1,7 +1,7 @@
from itertools import chain as chain
from socket import socket as socket_
from threading import Semaphore, Thread
from typing import Any, Callable, Iterable, Literal, TypeVar
from typing import Any, Callable, Literal, TypeVar
import werkzeug.serving
from gevent.pywsgi import WSGIServer
@@ -71,7 +71,6 @@ class FSWatcherInotify(FSWatcherBase):
class CommonServer:
app: Any
_on_stop_funcs: list[Callable]
interface: str
port: int
pid: int
@@ -167,7 +166,6 @@ class Worker:
def start(self) -> None: ...
def stop(self) -> None: ...
def run(self) -> None: ...
def _runloop(self) -> None: ...
class WorkerHTTP(Worker):
sock_timeout: float
@@ -182,7 +180,6 @@ class WorkerCron(Worker):
watchdog_timeout: int
def __init__(self, multi: PreforkServer) -> None: ...
def sleep(self) -> None: ...
def _db_list(self): ...
def process_work(self) -> None: ...
dbcursor: Cursor
def start(self) -> None: ...
@@ -191,7 +188,6 @@ class WorkerCron(Worker):
server: CommonServer | None
def load_server_wide_modules() -> None: ...
def _reexec(updated_modules: Iterable[str] | None = ...) -> None: ...
def load_test_file_py(registry: Registry, test_file: str) -> None: ...
def preload_registries(dbnames: list[str] | None): ...
def start(preload: list[str] | None = ..., stop: bool = ...): ...