tjh.dev
nixpkgs mirror (for testing)
github.com/NixOS/nixpkgs
nix
1{ lib, buildPythonPackage, fetchPypi, fetchpatch
2, tornado
3, toolz
4, zict
5, six
6, pytest
7, networkx
8, distributed
9, confluent-kafka
10, graphviz
11, requests
12}:
13
14buildPythonPackage rec {
15 pname = "streamz";
16 version = "0.5.2";
17
18 src = fetchPypi {
19 inherit pname version;
20 sha256 = "127rpdjgkcyjifmkqbhmqfbzlgi32n54rybrdxja610qr906y40c";
21 };
22
23 patches = [
24 # fix networkx rename issue of GiGraph.node -> DiGraph.nodes, remove on next bump
25 ( fetchpatch {
26 url = "https://github.com/python-streamz/streamz/commit/f8b7bdb6bcb9dd107677e82e755ff4695bf0c4be.patch";
27 sha256 = "1b2frp0j369gf55plxk2pigblhsc44m0rm9az01y83cjlcm26x2s";
28 })
29 # also, fix networkx rename issue of GiGraph.node -> DiGraph.nodes, remove on next bump
30 ( fetchpatch {
31 url = "https://github.com/python-streamz/streamz/commit/f7603f4cbea54f1548885881206a3ca9d6e52250.patch";
32 sha256 = "1125kqiaz6b3cifz0yk1zrkxj5804lfzl4kc58jhqajv8rsrbs45";
33 })
34 ];
35
36 propagatedBuildInputs = [
37 networkx
38 tornado
39 toolz
40 zict
41 six
42 ];
43
44 checkInputs = [
45 confluent-kafka
46 distributed
47 graphviz
48 pytest
49 requests
50 ];
51
52 # Disable test_tcp_async because fails on sandbox build
53 # disable kafka tests
54 checkPhase = ''
55 pytest --deselect=streamz/tests/test_sources.py::test_tcp_async \
56 --deselect=streamz/tests/test_sources.py::test_tcp \
57 --ignore=streamz/tests/test_kafka.py
58 '';
59
60 meta = with lib; {
61 description = "Pipelines to manage continuous streams of data";
62 homepage = "https://github.com/python-streamz/streamz";
63 license = licenses.bsd3;
64 maintainers = [ maintainers.costrouc ];
65 broken = true;
66 };
67}