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