Skip to content

Commit

Permalink
*shakes fist at isort*.
Browse files Browse the repository at this point in the history
  • Loading branch information
alxmrs committed Jan 30, 2025
1 parent 5952e74 commit dfa2813
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 7 deletions.
3 changes: 1 addition & 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,9 @@
transformations across processes and workers via Dask distributed's
scheduler.
"""
import dataclasses

import argparse
import collections
import dataclasses
import typing as t

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

import typing as t

import apache_beam as beam
Expand Down
7 changes: 3 additions & 4 deletions sdks/python/apache_beam/runners/dask/transform_evaluator.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,15 +20,14 @@
A minimum set of operation substitutions, to adap Beam's PTransform model
to Dask Bag functions.
"""
import dataclasses
from dataclasses import field

import abc
import dask.bag as db
import dataclasses
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 dfa2813

Please sign in to comment.