Passing lint via the run_pylint.sh script.

sdks/python/apache_beam/runners/dask/dask_runner.py

@@ -60,7 +60,7 @@ def _parse_timeout(candidate):
 
   @staticmethod
   def _extract_bag_kwargs(dask_options: t.Dict) -> t.Dict:
-    """Parse keyword arguments for `dask.Bag`s, used during graph translation."""
+    """Parse keyword arguments for `dask.Bag`s; used in graph translation."""
     out = {}
 
     if npartitions := dask_options.pop('npartitions', None):

sdks/python/apache_beam/runners/dask/overrides.py

@@ -15,6 +15,7 @@
 # limitations under the License.
 #
 import dataclasses
+
 import typing as t
 
 import apache_beam as beam

sdks/python/apache_beam/runners/dask/transform_evaluator.py

@@ -20,14 +20,15 @@
 A minimum set of operation substitutions, to adap Beam's PTransform model
 to Dask Bag functions.
 """
-import abc
 import dataclasses
+from dataclasses import field
+
+import abc
+import dask.bag as db
 import math
 import typing as t
-from dataclasses import field
 
 import apache_beam
-import dask.bag as db
 from apache_beam import DoFn
 from apache_beam import TaggedOutput
 from apache_beam.pipeline import AppliedPTransform