fix lint

apache · Nov 7, 2024 · 7caba84 · 7caba84
1 parent be190d2
commit 7caba84
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)