@@ -14,6 +14,7 @@
1414, toolz
1515, tornado
1616, zict
17+, fetchpatch
1718}:
1819
1920buildPythonPackage rec {
@@ -28,6 +29,16 @@ buildPythonPackage rec {
2829 sha256 = "sha256-0wZ1ldLFRAIL9R+gLfwsFbL+gvdORAkYWNjnDmeafm8=";
2930 };
3031
32+ patches = [
33+ # remove with next bump
34+ (fetchpatch {
35+ name = "fix-tests-against-distributed-2021.10.0.patch";
36+ url = "https://github.com/python-streamz/streamz/commit/5bd3bc4d305ff40c740bc2550c8491be9162778a.patch";
37+ sha256 = "1xzxcbf7yninkyizrwm3ahqk6ij2fmh0454iqjx2n7mmzx3sazx7";
38+ includes = ["streamz/tests/test_dask.py"];
39+ })
40+ ];
41+
3142 propagatedBuildInputs = [
3243 networkx
3344 six
@@ -46,22 +57,23 @@ buildPythonPackage rec {
4657 requests
4758 ];
4859
60+ pythonImportsCheck = [
61+ "streamz"
62+ ];
63+
4964 disabledTests = [
50− # Disable test_tcp_async because fails on sandbox build
51− "test_partition_timeout"
65+ # test_tcp_async fails on sandbox build
5266 "test_tcp_async"
5367 "test_tcp"
68+ "test_partition_timeout"
69+ # flaky
70+ "test_from_iterable_backpressure"
5471 ];
55−
5672 disabledTestPaths = [
57− # Disable kafka tests
73+ # disable kafka tests
5874 "streamz/tests/test_kafka.py"
5975 ];
6076
61− pythonImportsCheck = [
62− "streamz"
63− ];
64−
6577 meta = with lib; {
6678 description = "Pipelines to manage continuous streams of data";
6779 homepage = "https://github.com/python-streamz/streamz";