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