anchor.diff:    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
     '';
   
  
positive.code: { lib, buildPythonPackage, fetchPypi
  , confluent-kafka
  , distributed
  , flaky
  
negative.code:     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
  