anchor.diff: -{ lib, buildPythonPackage, fetchPypi
  +{ lib
  +, buildPythonPackage
  +, fetchPypi
  +, fetchpatch
   , confluent-kafka
   , distributed
   , flaky
  
positive.code:     inherit pname version;
      sha256 = "04446ece273c041506b1642bd3d8380367a8372196be4d6d6d03faafadc590b2";
    };
  
    propagatedBuildInputs = [
      networkx
  
negative.code:   checkPhase = ''
      pytest --deselect=streamz/tests/test_sources.py::test_tcp_async \
        --deselect=streamz/tests/test_sources.py::test_tcp \
        --deselect=streamz/tests/test_core.py::test_partition_timeout \
        --ignore=streamz/tests/test_kafka.py
    '';
  
  