Skip to content

Commit

Permalink
Fixing all run_pylint.sh issues.
Browse files Browse the repository at this point in the history
  • Loading branch information
alxmrs committed Jan 29, 2025
1 parent 2fd9a6e commit 5952e74
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 7 deletions.
5 changes: 3 additions & 2 deletions sdks/python/apache_beam/runners/dask/dask_runner.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,10 +21,11 @@
transformations across processes and workers via Dask distributed's
scheduler.
"""
import argparse
import dataclasses
import typing as t

import argparse
import collections
import typing as t

from apache_beam import pvalue
from apache_beam.options.pipeline_options import PipelineOptions
Expand Down
1 change: 1 addition & 0 deletions sdks/python/apache_beam/runners/dask/overrides.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@
# limitations under the License.
#
import dataclasses

import typing as t

import apache_beam as beam
Expand Down
9 changes: 4 additions & 5 deletions sdks/python/apache_beam/runners/dask/transform_evaluator.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,17 +19,16 @@
A minimum set of operation substitutions, to adap Beam's PTransform model
to Dask Bag functions.
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
Expand Down

0 comments on commit 5952e74

Please sign in to comment.