pyrox.dev
1{ stdenv
2, lib
3, buildPythonPackage
4, confluent-kafka
5, distributed
6, fetchpatch
7, fetchPypi
8, flaky
9, graphviz
10, networkx
11, pytest-asyncio
12, pytestCheckHook
13, pythonOlder
14, requests
15, six
16, toolz
17, tornado
18, zict
19}:
20
21buildPythonPackage rec {
22 pname = "streamz";
23 version = "0.6.4";
24 format = "setuptools";
25
26 disabled = pythonOlder "3.6";
27
28 src = fetchPypi {
29 inherit pname version;
30 hash = "sha256-VXfWkEwuxInBQVQJV3IQXgGVRkiBmYfUZCBMbjyWNPM=";
31 };
32
33 propagatedBuildInputs = [
34 networkx
35 six
36 toolz
37 tornado
38 zict
39 ];
40
41 nativeCheckInputs = [
42 confluent-kafka
43 distributed
44 flaky
45 graphviz
46 pytest-asyncio
47 pytestCheckHook
48 requests
49 ];
50
51 pythonImportsCheck = [
52 "streamz"
53 ];
54
55 disabledTests = [
56 # Error with distutils version: fixture 'cleanup' not found
57 "test_separate_thread_without_time"
58 "test_await_syntax"
59 "test_partition_then_scatter_sync"
60 "test_sync"
61 "test_sync_2"
62 # Test fail in the sandbox
63 "test_tcp_async"
64 "test_tcp"
65 "test_partition_timeout"
66 # Tests are flaky
67 "test_from_iterable"
68 "test_buffer"
69 ];
70
71 disabledTestPaths = [
72 # Disable kafka tests
73 "streamz/tests/test_kafka.py"
74 ];
75
76 meta = with lib; {
77 broken = stdenv.isDarwin;
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; [ ];
82 };
83}