Remove future imports (#2897)

distributed/__init__.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from . import config
 from dask.config import config
 from .actor import Actor, ActorFuture

distributed/_ipython_utils.py

@@ -4,8 +4,6 @@
 after which we can import them instead of having our own definitions.
 """
 
-from __future__ import print_function
-
 import atexit
 import os
 

distributed/batched.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from collections import deque
 import logging
 

distributed/cfexecutor.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import concurrent.futures as cf
 import weakref
 

distributed/cli/dask_remote.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import click
 from distributed.cli.utils import check_python_3, install_signal_handlers
 from distributed.submit import _remote

distributed/cli/dask_scheduler.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import atexit
 import logging
 import gc

distributed/cli/dask_ssh.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from distributed.deploy.ssh import SSHCluster
 import click
 

distributed/cli/dask_worker.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import atexit
 import logging
 import multiprocessing

distributed/cli/tests/test_dask_scheduler.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import pytest
 
 pytest.importorskip("requests")

distributed/cli/tests/test_dask_worker.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import pytest
 from click.testing import CliRunner
 

distributed/cli/tests/test_tls_cli.py

@@ -1,8 +1,5 @@
-from __future__ import print_function, division, absolute_import
-
 from time import sleep
 
-
 from distributed import Client
 from distributed.utils_test import (
     popen,

distributed/cli/utils.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from tornado import gen
 from tornado.ioloop import IOLoop
 

distributed/client.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import atexit
 from collections import defaultdict, Iterator
 from concurrent.futures import ThreadPoolExecutor, CancelledError

distributed/comm/__init__.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from .addressing import (
     parse_address,
     unparse_address,

distributed/comm/addressing.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import six
 
 import dask

distributed/comm/core.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from abc import ABCMeta, abstractmethod, abstractproperty
 from datetime import timedelta
 import logging

distributed/comm/inproc.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from collections import deque, namedtuple
 import itertools
 import logging

distributed/comm/registry.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from abc import ABCMeta, abstractmethod
 
 from six import with_metaclass

distributed/comm/tcp.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import errno
 import logging
 import socket

distributed/comm/tests/test_comms.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from functools import partial
 import os
 import sys

distributed/comm/utils.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from concurrent.futures import ThreadPoolExecutor
 import logging
 import socket

distributed/compatibility.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import logging
 import platform
 import sys

distributed/config.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import logging
 import logging.config
 import os

distributed/core.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import asyncio
 from collections import defaultdict, deque
 from concurrent.futures import CancelledError

distributed/counter.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from collections import defaultdict
 
 from tornado.ioloop import IOLoop

distributed/dashboard/components.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import asyncio
 from bisect import bisect
 from operator import add

distributed/dashboard/core.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from distutils.version import LooseVersion
 import os
 import warnings

distributed/dashboard/export_tool.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import os
 
 from bokeh.core.properties import Int, String

distributed/dashboard/scheduler.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from functools import partial
 import logging
 import math

distributed/dashboard/tests/test_components.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import pytest
 
 pytest.importorskip("bokeh")

distributed/dashboard/tests/test_scheduler_bokeh.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import json
 import re
 import ssl

distributed/dashboard/tests/test_scheduler_bokeh_html.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import json
 import re
 import xml.etree.ElementTree

distributed/dashboard/tests/test_worker_bokeh.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from operator import add, sub
 import re
 from time import sleep

distributed/dashboard/utils.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from distutils.version import LooseVersion
 import os
 

distributed/dashboard/worker.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from functools import partial
 import logging
 import math

distributed/deploy/__init__.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from ..utils import ignoring
 
 from .cluster import Cluster

distributed/deploy/adaptive.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from collections import deque
 import logging
 

distributed/deploy/local.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import atexit
 import logging
 import math

distributed/deploy/ssh.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import logging
 import socket
 import os

distributed/deploy/tests/test_adaptive.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from time import sleep
 
 import pytest

distributed/deploy/tests/test_local.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from functools import partial
 import gc
 import multiprocessing

distributed/deploy/tests/test_ssh.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from time import sleep
 
 import pytest

distributed/diagnostics/__init__.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from ..utils import ignoring
 from .graph_layout import GraphLayout
 

distributed/diagnostics/eventstream.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import logging
 
 from .plugin import SchedulerPlugin

distributed/diagnostics/graph_layout.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from .plugin import SchedulerPlugin
 
 

distributed/diagnostics/plugin.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import logging
 
 logger = logging.getLogger(__name__)

distributed/diagnostics/progress.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from collections import defaultdict
 import logging
 from timeit import default_timer

distributed/diagnostics/progress_stream.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import logging
 
 from toolz import valmap, merge

distributed/diagnostics/progressbar.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import logging
 import html
 from timeit import default_timer

distributed/diagnostics/task_stream.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from collections import deque
 import logging
 

distributed/diagnostics/tests/test_eventstream.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import collections
 
 import pytest

distributed/diagnostics/tests/test_plugin.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from distributed import Worker
 from distributed.utils_test import inc, gen_cluster
 from distributed.diagnostics.plugin import SchedulerPlugin

distributed/diagnostics/tests/test_progress.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import pytest
 
 from tornado import gen

distributed/diagnostics/tests/test_progress_stream.py

@@ -1,6 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
-
 import pytest
 
 pytest.importorskip("bokeh")

distributed/diagnostics/tests/test_progressbar.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from time import sleep
 
 import pytest

distributed/diagnostics/tests/test_task_stream.py

@@ -1,5 +1,3 @@
-from __future__ import absolute_import, division, print_function
-
 import os
 from time import sleep
 

distributed/diagnostics/tests/test_widgets.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import pytest
 
 pytest.importorskip("ipywidgets")

distributed/diskutils.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import errno
 import glob
 import logging

distributed/lock.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from collections import defaultdict, deque
 from datetime import timedelta
 import logging

distributed/metrics.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import collections
 from functools import wraps
 import sys

distributed/nanny.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 from datetime import timedelta
 import logging
 from multiprocessing.queues import Empty

distributed/node.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import logging
 import warnings
 import weakref

distributed/process.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import atexit
 from datetime import timedelta
 import logging

distributed/proctitle.py

@@ -1,5 +1,3 @@
-from __future__ import print_function, division, absolute_import
-
 import os
 
 try:

distributed/profile.py

@@ -24,8 +24,6 @@
                    'children': {...}}}
     }
 """
-from __future__ import print_function, division, absolute_import
-
 import bisect
 from collections import defaultdict, deque
 import linecache