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