anchor.diff:      inherit pname version;
       sha256 = "04446ece273c041506b1642bd3d8380367a8372196be4d6d6d03faafadc590b2";
     };
  +
  +  patches = [
  +    # Fix apply import from dask
  +    (fetchpatch {
  +      url = "https://patch-diff.githubusercontent.com/raw/python-streamz/streamz/pull/423.patch";
  +      sha256 = "sha256-CR+uRvzaFu9WQ633tbvX3gAnudhlVN6VvmxKiR37diw=";
  +    })
  +  ];
   
     propagatedBuildInputs = [
       networkx
  
positive.code:   checkPhase = ''
      pytest --deselect=streamz/tests/test_sources.py::test_tcp_async \
        --deselect=streamz/tests/test_sources.py::test_tcp \
        --ignore=streamz/tests/test_kafka.py
    '';
  
  
negative.code: { lib
  , buildPythonPackage
  , fetchPypi
  , fetchpatch
  , confluent-kafka
  , distributed
  , flaky
  