tjh.dev
1{ lib, buildPythonPackage, fetchPypi
2, confluent-kafka
3, distributed
4, flaky
5, graphviz
6, networkx
7, pytest
8, requests
9, six
10, toolz
11, tornado
12, zict
13, pythonOlder
14}:
15
16buildPythonPackage rec {
17 pname = "streamz";
18 version = "0.6.2";
19
20 src = fetchPypi {
21 inherit pname version;
22 sha256 = "04446ece273c041506b1642bd3d8380367a8372196be4d6d6d03faafadc590b2";
23 };
24
25 propagatedBuildInputs = [
26 networkx
27 tornado
28 toolz
29 zict
30 six
31 ];
32
33 checkInputs = [
34 confluent-kafka
35 distributed
36 flaky
37 graphviz
38 pytest
39 requests
40 ];
41
42 disabled = pythonOlder "3.6";
43
44 # Disable test_tcp_async because fails on sandbox build
45 # disable kafka tests
46 checkPhase = ''
47 pytest --deselect=streamz/tests/test_sources.py::test_tcp_async \
48 --deselect=streamz/tests/test_sources.py::test_tcp \
49 --ignore=streamz/tests/test_kafka.py
50 '';
51
52 meta = with lib; {
53 description = "Pipelines to manage continuous streams of data";
54 homepage = "https://github.com/python-streamz/streamz";
55 license = licenses.bsd3;
56 maintainers = [ maintainers.costrouc ];
57 };
58}