803c563622
They are prone to race conditions.
```
_______________________________ test_sched_error _______________________________
caplog = <_pytest.logging.LogCaptureFixture object at 0x197218a90>
@pytest.mark.slow
def test_sched_error(caplog):
caplog.set_level(logging.WARNING, logger="psycopg")
s = Scheduler()
t = Thread(target=s.run, daemon=True)
t.start()
results = []
def worker(i):
results.append((i, time()))
def error():
1 / 0
t0 = time()
s.enter(0.1, partial(worker, 1))
s.enter(0.4, None)
s.enter(0.3, partial(worker, 2))
s.enter(0.2, error)
t.join()
t1 = time()
assert t1 - t0 == pytest.approx(0.4, 0.1)
assert len(results) == 2
assert results[0][0] == 1
> assert results[0][1] - t0 == pytest.approx(0.1, 0.1)
E assert 0.11003494262695312 == 0.1 ± 1.0e-02
E comparison failed
E Obtained: 0.11003494262695312
E Expected: 0.1 ± 1.0e-02
tests/pool/test_sched.py:93: AssertionError
```
214 lines
3.7 KiB
Nix
214 lines
3.7 KiB
Nix
{ lib
|
|
, stdenv
|
|
, buildPythonPackage
|
|
, fetchFromGitHub
|
|
, fetchurl
|
|
, pythonOlder
|
|
, substituteAll
|
|
|
|
# build
|
|
, postgresql
|
|
, setuptools
|
|
|
|
# propagates
|
|
, backports-zoneinfo
|
|
, typing-extensions
|
|
|
|
# psycopg-c
|
|
, cython_3
|
|
|
|
# docs
|
|
, furo
|
|
, shapely
|
|
, sphinxHook
|
|
, sphinx-autodoc-typehints
|
|
|
|
# tests
|
|
, pproxy
|
|
, pytest-asyncio
|
|
, pytest-randomly
|
|
, pytestCheckHook
|
|
}:
|
|
|
|
let
|
|
pname = "psycopg";
|
|
version = "3.0.16";
|
|
|
|
src = fetchFromGitHub {
|
|
owner = "psycopg";
|
|
repo = pname;
|
|
rev = version;
|
|
hash = "sha256-jKhpmCcDi7FyMSpn51eSukFvmu3yacNovmRYG9jnu3g=";
|
|
};
|
|
|
|
patches = [
|
|
(substituteAll {
|
|
src = ./libpq.patch;
|
|
libpq = "${postgresql.lib}/lib/libpq${stdenv.hostPlatform.extensions.sharedLibrary}";
|
|
})
|
|
];
|
|
|
|
baseMeta = {
|
|
changelog = "https://github.com/psycopg/psycopg/blob/master/docs/news.rst";
|
|
homepage = "https://github.com/psycopg/psycopg";
|
|
license = lib.licenses.lgpl3Plus;
|
|
maintainers = with lib.maintainers; [ hexa ];
|
|
};
|
|
|
|
psycopg-c = buildPythonPackage {
|
|
pname = "${pname}-c";
|
|
inherit version src;
|
|
format = "pyproject";
|
|
|
|
# apply patches to base repo
|
|
inherit patches;
|
|
|
|
# move into source root after patching
|
|
postPatch = ''
|
|
cd psycopg_c
|
|
'';
|
|
|
|
nativeBuildInputs = [
|
|
setuptools
|
|
cython_3
|
|
postgresql
|
|
];
|
|
|
|
# tested in psycopg
|
|
doCheck = false;
|
|
|
|
meta = baseMeta // {
|
|
description = "C optimisation distribution for Psycopg";
|
|
};
|
|
};
|
|
|
|
psycopg-pool = buildPythonPackage {
|
|
pname = "${pname}-pool";
|
|
inherit version src;
|
|
format = "setuptools";
|
|
|
|
# apply patches to base repo
|
|
inherit patches;
|
|
|
|
# move into source root after patching
|
|
postPatch = ''
|
|
cd psycopg_pool
|
|
'';
|
|
|
|
propagatedBuildInputs = lib.optionals (pythonOlder "3.10") [
|
|
typing-extensions
|
|
];
|
|
|
|
# tested in psycopg
|
|
doCheck = false;
|
|
|
|
meta = baseMeta // {
|
|
description = "Connection Pool for Psycopg";
|
|
};
|
|
};
|
|
|
|
in
|
|
|
|
buildPythonPackage rec {
|
|
inherit pname version src;
|
|
format = "pyproject";
|
|
|
|
disabled = pythonOlder "3.7";
|
|
|
|
outputs = [
|
|
"out"
|
|
"doc"
|
|
];
|
|
|
|
sphinxRoot = "../docs";
|
|
|
|
# Introduce this file necessary for the docs build via environment var
|
|
LIBPQ_DOCS_FILE = fetchurl {
|
|
url = "https://raw.githubusercontent.com/postgres/postgres/REL_14_STABLE/doc/src/sgml/libpq.sgml";
|
|
hash = "sha256-yn09fR9+7zQni8SvTG7BUmYRD7MK7u2arVAznWz2oAw=";
|
|
};
|
|
|
|
inherit patches;
|
|
|
|
# only move to sourceRoot after patching, makes patching easier
|
|
postPatch = ''
|
|
cd psycopg
|
|
'';
|
|
|
|
nativeBuildInputs = [
|
|
furo
|
|
setuptools
|
|
shapely
|
|
sphinx-autodoc-typehints
|
|
sphinxHook
|
|
];
|
|
|
|
propagatedBuildInputs = [
|
|
psycopg-c
|
|
] ++ lib.optionals (pythonOlder "3.11") [
|
|
typing-extensions
|
|
] ++ lib.optionals (pythonOlder "3.9") [
|
|
backports-zoneinfo
|
|
];
|
|
|
|
pythonImportsCheck = [
|
|
"psycopg"
|
|
"psycopg_c"
|
|
"psycopg_pool"
|
|
];
|
|
|
|
passthru.optional-dependencies = {
|
|
c = [ psycopg-c ];
|
|
pool = [ psycopg-pool ];
|
|
};
|
|
|
|
preCheck = ''
|
|
cd ..
|
|
'';
|
|
|
|
checkInputs = [
|
|
pproxy
|
|
pytest-asyncio
|
|
pytest-randomly
|
|
pytestCheckHook
|
|
postgresql
|
|
]
|
|
++ passthru.optional-dependencies.c
|
|
++ passthru.optional-dependencies.pool;
|
|
|
|
disabledTests = [
|
|
# don't depend on mypy for tests
|
|
"test_version"
|
|
"test_package_version"
|
|
] ++ lib.optionals (stdenv.isDarwin) [
|
|
# racy test
|
|
"test_sched"
|
|
"test_sched_error"
|
|
];
|
|
|
|
disabledTestPaths = [
|
|
# Network access
|
|
"tests/test_dns.py"
|
|
"tests/test_dns_srv.py"
|
|
# Mypy typing test
|
|
"tests/test_typing.py"
|
|
];
|
|
|
|
pytestFlagsArray = [
|
|
"-o cache_dir=$TMPDIR"
|
|
];
|
|
|
|
postCheck = ''
|
|
cd ${pname}
|
|
'';
|
|
|
|
passthru = {
|
|
c = psycopg-c;
|
|
pool = psycopg-pool;
|
|
};
|
|
|
|
meta = baseMeta // {
|
|
description = "PostgreSQL database adapter for Python";
|
|
};
|
|
}
|