More readable fix for RUF017

Author: DimitriPapadopoulos

distributed/client.py

@@ -7,7 +7,6 @@
 import itertools
 import json
 import logging
-import operator
 import os
 import pickle
 import re
@@ -2298,27 +2297,23 @@ def map(
                 keys = [list(element) for element in partition_all(batch_size, key)]
             else:
                 keys = [key for _ in range(len(batches))]
-            return reduce(
-                operator.iadd,
-                (
-                    self.map(
-                        func,
-                        *batch,
-                        key=key,
-                        workers=workers,
-                        retries=retries,
-                        priority=priority,
-                        allow_other_workers=allow_other_workers,
-                        fifo_timeout=fifo_timeout,
-                        resources=resources,
-                        actor=actor,
-                        actors=actors,
-                        pure=pure,
-                        **kwargs,
-                    )
-                    for key, batch in zip(keys, batches)
-                ),
-                [],
+            return list(flatten(
+                self.map(
+                    func,
+                    *batch,
+                    key=key,
+                    workers=workers,
+                    retries=retries,
+                    priority=priority,
+                    allow_other_workers=allow_other_workers,
+                    fifo_timeout=fifo_timeout,
+                    resources=resources,
+                    actor=actor,
+                    actors=actors,
+                    pure=pure,
+                    **kwargs,
+                )
+                for key, batch in zip(keys, batches)
             )
 
         key = key or funcname(func)

distributed/utils.py

@@ -61,13 +61,12 @@
 except ImportError:
     resource = None  # type: ignore
 
-import operator
-
 import tlz as toolz
 from tornado import gen
 from tornado.ioloop import IOLoop
 
 import dask
+from dask.core import flatten
 from dask.utils import _deprecated, key_split
 from dask.utils import ensure_bytes as _ensure_bytes
 from dask.utils import parse_timedelta as _parse_timedelta
@@ -1475,11 +1474,9 @@ def convert_value(v):
             out = '"' + out + '"'
         return out
 
-    return functools.reduce(
-        operator.iadd,
-        (["--" + k.replace("_", "-"), convert_value(v)] for k, v in d.items()),
-        [],
-    )
+    return list(flatten(
+        ["--" + k.replace("_", "-"), convert_value(v)] for k, v in d.items()
+    ))
 
 
 def is_valid_xml(text):