diff --git a/sdks/python/apache_beam/transforms/core.py b/sdks/python/apache_beam/transforms/core.py index 66b82c8287e9f..ae324ce991fb9 100644 --- a/sdks/python/apache_beam/transforms/core.py +++ b/sdks/python/apache_beam/transforms/core.py @@ -797,7 +797,7 @@ def get_output_batch_type( self, input_element_type ) -> typing.Optional[typing.Union[TypeConstraint, type]]: """Determine the batch type produced by this DoFn's ``process_batch`` - implementation and/or it's ``process`` implementation with + implementation and/or its ``process`` implementation with ``@yields_batch``. The default implementation of this method observes the return type