|
|
|
@ -3,6 +3,7 @@ |
|
|
|
|
, buildPythonPackage |
|
|
|
|
, confluent-kafka |
|
|
|
|
, distributed |
|
|
|
|
, fetchpatch |
|
|
|
|
, fetchPypi |
|
|
|
|
, flaky |
|
|
|
|
, graphviz |
|
|
|
@ -15,7 +16,6 @@ |
|
|
|
|
, toolz |
|
|
|
|
, tornado |
|
|
|
|
, zict |
|
|
|
|
, fetchpatch |
|
|
|
|
}: |
|
|
|
|
|
|
|
|
|
buildPythonPackage rec { |
|
|
|
@ -27,7 +27,7 @@ buildPythonPackage rec { |
|
|
|
|
|
|
|
|
|
src = fetchPypi { |
|
|
|
|
inherit pname version; |
|
|
|
|
sha256 = "sha256-0wZ1ldLFRAIL9R+gLfwsFbL+gvdORAkYWNjnDmeafm8="; |
|
|
|
|
hash = "sha256-0wZ1ldLFRAIL9R+gLfwsFbL+gvdORAkYWNjnDmeafm8="; |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
patches = [ |
|
|
|
@ -36,7 +36,9 @@ buildPythonPackage rec { |
|
|
|
|
name = "fix-tests-against-distributed-2021.10.0.patch"; |
|
|
|
|
url = "https://github.com/python-streamz/streamz/commit/5bd3bc4d305ff40c740bc2550c8491be9162778a.patch"; |
|
|
|
|
sha256 = "1xzxcbf7yninkyizrwm3ahqk6ij2fmh0454iqjx2n7mmzx3sazx7"; |
|
|
|
|
includes = ["streamz/tests/test_dask.py"]; |
|
|
|
|
includes = [ |
|
|
|
|
"streamz/tests/test_dask.py" |
|
|
|
|
]; |
|
|
|
|
}) |
|
|
|
|
]; |
|
|
|
|
|
|
|
|
@ -63,15 +65,17 @@ buildPythonPackage rec { |
|
|
|
|
]; |
|
|
|
|
|
|
|
|
|
disabledTests = [ |
|
|
|
|
# test_tcp_async fails on sandbox build |
|
|
|
|
# Test fail in the sandbox |
|
|
|
|
"test_tcp_async" |
|
|
|
|
"test_tcp" |
|
|
|
|
"test_partition_timeout" |
|
|
|
|
# flaky |
|
|
|
|
"test_from_iterable_backpressure" |
|
|
|
|
# Tests are flaky |
|
|
|
|
"test_from_iterable" |
|
|
|
|
"test_buffer" |
|
|
|
|
]; |
|
|
|
|
|
|
|
|
|
disabledTestPaths = [ |
|
|
|
|
# disable kafka tests |
|
|
|
|
# Disable kafka tests |
|
|
|
|
"streamz/tests/test_kafka.py" |
|
|
|
|
]; |
|
|
|
|
|
|
|
|
|