anchor.diff:  , buildPythonPackage
   , confluent-kafka
   , distributed
  +, fetchpatch
   , fetchPypi
   , flaky
   , graphviz
  
positive.code:   ];
  
    disabledTests = [
      # test_tcp_async fails on sandbox build
      "test_tcp_async"
      "test_tcp"
      "test_partition_timeout"
      # flaky
      "test_from_iterable_backpressure"
    ];
    disabledTestPaths = [
      # disable kafka tests
      "streamz/tests/test_kafka.py"
    ];
  
  
negative.code: 
    src = fetchPypi {
      inherit pname version;
      hash = "sha256-0wZ1ldLFRAIL9R+gLfwsFbL+gvdORAkYWNjnDmeafm8=";
    };
  
    patches = [
  