anchor.diff:      requests
     ];
   
  +  pythonImportsCheck = [
  +    "streamz"
  +  ];
  +
     disabledTests = [
  -    # Disable test_tcp_async because fails on sandbox build
  -    "test_partition_timeout"
  +    # test_tcp_async fails on sandbox build
       "test_tcp_async"
       "test_tcp"
  +    "test_partition_timeout"
  +    # flaky
  +    "test_from_iterable_backpressure"
     ];
  -
     disabledTestPaths = [
  -    # Disable kafka tests
  +    # disable kafka tests
       "streamz/tests/test_kafka.py"
  -  ];
  -
  -  pythonImportsCheck = [
  -    "streamz"
     ];
   
     meta = with lib; {
  
positive.code:     inherit pname version;
      sha256 = "sha256-0wZ1ldLFRAIL9R+gLfwsFbL+gvdORAkYWNjnDmeafm8=";
    };
  
    propagatedBuildInputs = [
      networkx
  
negative.code: , toolz
  , tornado
  , zict
  , fetchpatch
  }:
  
  buildPythonPackage rec {
  