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