From 7caba8494efc1841a8ea4b72b2933e0bc0f55e54 Mon Sep 17 00:00:00 2001 From: Alex Merose Date: Fri, 8 Nov 2024 07:50:55 +0800 Subject: [PATCH] fix lint --- sdks/python/apache_beam/runners/dask/transform_evaluator.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/runners/dask/transform_evaluator.py b/sdks/python/apache_beam/runners/dask/transform_evaluator.py index c2580ac7af49..ca0159e1b2dd 100644 --- a/sdks/python/apache_beam/runners/dask/transform_evaluator.py +++ b/sdks/python/apache_beam/runners/dask/transform_evaluator.py @@ -158,7 +158,7 @@ def apply(self, input_bag: OpInput, side_inputs: OpSide = None) -> db.Bag: def apply_dofn_to_bundle( items, do_fn_invoker_args, do_fn_invoker_kwargs, tagged_receivers): - """Invokes a DoFn within a bundle, which is implemented as a Dask partition.""" + """Invokes a DoFn within a bundle, implemented as a Dask partition.""" do_fn_invoker = DoFnInvoker.create_invoker( *do_fn_invoker_args, **do_fn_invoker_kwargs)