Passing lint via the run_pylint.sh script.

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

@@ -21,8 +21,9 @@
 transformations across processes and workers via Dask distributed's
 scheduler.
 """
-import argparse
 import dataclasses
+
+import argparse
 import typing as t
 
 from apache_beam import pvalue
@@ -59,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

@@ -22,14 +22,15 @@
 
 TODO(alxr): Translate ops from https://docs.dask.org/en/latest/bag-api.html.
 """
-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