tjh.dev
nixpkgs mirror (for testing)
github.com/NixOS/nixpkgs
nix
1{ stdenv
2, lib
3, buildPythonPackage
4, confluent-kafka
5, distributed
6, fetchPypi
7, flaky
8, graphviz
9, networkx
10, pytest-asyncio
11, pytestCheckHook
12, pythonOlder
13, requests
14, six
15, toolz
16, tornado
17, zict
18, fetchpatch
19}:
20
21buildPythonPackage rec {
22 pname = "streamz";
23 version = "0.6.3";
24 format = "setuptools";
25
26 disabled = pythonOlder "3.6";
27
28 src = fetchPypi {
29 inherit pname version;
30 sha256 = "sha256-0wZ1ldLFRAIL9R+gLfwsFbL+gvdORAkYWNjnDmeafm8=";
31 };
32
33 patches = [
34 # remove with next bump
35 (fetchpatch {
36 name = "fix-tests-against-distributed-2021.10.0.patch";
37 url = "https://github.com/python-streamz/streamz/commit/5bd3bc4d305ff40c740bc2550c8491be9162778a.patch";
38 sha256 = "1xzxcbf7yninkyizrwm3ahqk6ij2fmh0454iqjx2n7mmzx3sazx7";
39 includes = ["streamz/tests/test_dask.py"];
40 })
41 ];
42
43 propagatedBuildInputs = [
44 networkx
45 six
46 toolz
47 tornado
48 zict
49 ];
50
51 checkInputs = [
52 confluent-kafka
53 distributed
54 flaky
55 graphviz
56 pytest-asyncio
57 pytestCheckHook
58 requests
59 ];
60
61 pythonImportsCheck = [
62 "streamz"
63 ];
64
65 disabledTests = [
66 # test_tcp_async fails on sandbox build
67 "test_tcp_async"
68 "test_tcp"
69 "test_partition_timeout"
70 # flaky
71 "test_from_iterable_backpressure"
72 ];
73 disabledTestPaths = [
74 # disable kafka tests
75 "streamz/tests/test_kafka.py"
76 ];
77
78 meta = with lib; {
79 broken = stdenv.isDarwin;
80 description = "Pipelines to manage continuous streams of data";
81 homepage = "https://github.com/python-streamz/streamz";
82 license = licenses.bsd3;
83 maintainers = with maintainers; [ costrouc ];
84 };
85}