pyrox.dev
1{
2 lib,
3 stdenv,
4 buildPythonPackage,
5 pythonOlder,
6 fetchPypi,
7 setuptools,
8 confluent-kafka,
9 dask,
10 dask-expr,
11 distributed,
12 flaky,
13 graphviz,
14 networkx,
15 pytest-asyncio,
16 pytestCheckHook,
17 requests,
18 six,
19 toolz,
20 tornado,
21 zict,
22}:
23
24buildPythonPackage rec {
25 pname = "streamz";
26 version = "0.6.4";
27 pyproject = true;
28
29 disabled = pythonOlder "3.6";
30
31 src = fetchPypi {
32 inherit pname version;
33 hash = "sha256-VXfWkEwuxInBQVQJV3IQXgGVRkiBmYfUZCBMbjyWNPM=";
34 };
35
36 build-system = [ setuptools ];
37
38 dependencies = [
39 networkx
40 six
41 toolz
42 tornado
43 zict
44 ];
45
46 nativeCheckInputs = [
47 confluent-kafka
48 dask
49 dask-expr
50 distributed
51 flaky
52 graphviz
53 pytest-asyncio
54 pytestCheckHook
55 requests
56 ];
57
58 pythonImportsCheck = [ "streamz" ];
59
60 disabledTests = [
61 # Error with distutils version: fixture 'cleanup' not found
62 "test_separate_thread_without_time"
63 "test_await_syntax"
64 "test_partition_then_scatter_sync"
65 "test_sync"
66 "test_sync_2"
67 # Test fail in the sandbox
68 "test_tcp_async"
69 "test_tcp"
70 "test_partition_timeout"
71 # Tests are flaky
72 "test_from_iterable"
73 "test_buffer"
74 ];
75
76 disabledTestPaths = [
77 # Disable kafka tests
78 "streamz/tests/test_kafka.py"
79 ];
80
81 meta = with lib; {
82 broken = stdenv.isDarwin;
83 description = "Pipelines to manage continuous streams of data";
84 homepage = "https://github.com/python-streamz/streamz";
85 license = licenses.bsd3;
86 maintainers = with maintainers; [ ];
87 };
88}