remove six dependency

Author: a-detiste

ci/environment-py38.yml

@@ -11,7 +11,6 @@ dependencies:
   - tornado
   - toolz
   - zict
-  - six
   - librdkafka=1.5.3
   - dask
   - distributed

ci/environment-py39.yml

@@ -11,7 +11,6 @@ dependencies:
   - tornado
   - toolz
   - zict
-  - six
   - librdkafka=1.5.3
   - dask
   - distributed

requirements.txt

@@ -1,5 +1,4 @@
 tornado
 toolz
 zict
-six
-setuptools
+setuptools

streamz/core.py

@@ -4,8 +4,6 @@
 from itertools import chain
 import functools
 import logging
-import six
-import sys
 import threading
 from time import time
 from typing import Any, Callable, Hashable, Union
@@ -1947,8 +1945,8 @@ def f():
             if timeout is not None:
                 future = gen.with_timeout(timedelta(seconds=timeout), future)
             result[0] = yield future
-        except Exception:
-            error[0] = sys.exc_info()
+        except Exception as exc:
+            error[0] = exc
         finally:
             thread_state.asynchronous = False
             e.set()
@@ -1960,7 +1958,8 @@ def f():
     else:
         while not e.is_set():
             e.wait(10)
+
     if error[0]:
-        six.reraise(*error[0])
+        raise error[0]
     else:
         return result[0]

streamz/utils_test.py

@@ -1,8 +1,8 @@
 import asyncio
 from contextlib import contextmanager
+import io
 import logging
 import os
-import six
 import shutil
 import tempfile
 from time import time, sleep
@@ -85,7 +85,7 @@ def captured_logger(logger, level=logging.INFO, propagate=None):
     if propagate is not None:
         orig_propagate = logger.propagate
         logger.propagate = propagate
-    sio = six.StringIO()
+    sio = io.StringIO()
     logger.handlers[:] = [logging.StreamHandler(sio)]
     logger.setLevel(level)
     try: