Import from collections.abc

distributed/client.py

@@ -1,5 +1,6 @@
 import atexit
-from collections import defaultdict, Iterator
+from collections import defaultdict
+from collections.abc import Iterator
 from concurrent.futures import ThreadPoolExecutor, CancelledError
 from concurrent.futures._base import DoneAndNotDoneFutures
 from contextlib import contextmanager

distributed/publish.py

@@ -1,4 +1,4 @@
-from collections import MutableMapping
+from collections.abc import MutableMapping
 
 from .utils import log_errors, tokey
 

distributed/scheduler.py

@@ -1,5 +1,6 @@
 import asyncio
-from collections import defaultdict, deque, OrderedDict, Mapping, Set
+from collections import defaultdict, deque, OrderedDict
+from collections.abc import Mapping, Set
 from datetime import timedelta
 from functools import partial
 import itertools

distributed/tests/test_as_completed.py

@@ -1,5 +1,5 @@
 from concurrent.futures import CancelledError
-from collections import Iterator
+from collections.abc import Iterator
 from operator import add
 import queue
 import random

distributed/worker.py

@@ -1,6 +1,7 @@
 import asyncio
 import bisect
-from collections import defaultdict, deque, MutableMapping
+from collections import defaultdict, deque
+from collections.abc import MutableMapping
 from datetime import timedelta
 import heapq
 import logging