1{
2 lib,
3 buildPythonPackage,
4 fetchFromGitHub,
5
6 # build-system
7 setuptools,
8
9 # dependencies
10 six,
11 toolz,
12 tornado,
13 zict,
14
15 # tests
16 dask,
17 distributed,
18 flaky,
19 pandas,
20 pyarrow,
21 pytestCheckHook,
22}:
23
24buildPythonPackage rec {
25 pname = "streamz";
26 version = "0.6.4";
27 pyproject = true;
28
29 src = fetchFromGitHub {
30 owner = "python-streamz";
31 repo = "streamz";
32 tag = version;
33 hash = "sha256-lSb3gl+TSIzz4BZzxH8zXu74HvzSntOAoVQUUJKIEvA=";
34 };
35
36 build-system = [ setuptools ];
37
38 dependencies = [
39 six
40 toolz
41 tornado
42 zict
43 ];
44
45 nativeCheckInputs = [
46 dask
47 distributed
48 flaky
49 pandas
50 pyarrow
51 pytestCheckHook
52 ];
53
54 pythonImportsCheck = [ "streamz" ];
55
56 disabledTests = [
57 # Error with distutils version: fixture 'cleanup' not found
58 "test_separate_thread_without_time"
59 "test_await_syntax"
60 "test_partition_then_scatter_sync"
61 "test_sync"
62 "test_sync_2"
63
64 # Tests are flaky
65 "test_buffer"
66 "test_partition_timeout_cancel"
67 ];
68
69 __darwinAllowLocalNetworking = true;
70
71 meta = {
72 description = "Pipelines to manage continuous streams of data";
73 homepage = "https://github.com/python-streamz/streamz";
74 license = lib.licenses.bsd3;
75 maintainers = with lib.maintainers; [ GaetanLepage ];
76 };
77}