When creating a DoFn, if the process method returns None, we can issue a warning, such as no iterator is returned by the process method in DoFn. This could help users debug whether returning None is expected. Possible code changes could be in _check_fn_use_yield_and_return from https://github.com/apache/beam/blob/master/sdks/python/apache_beam/transforms/core.py.
What would you like to happen?
When creating a
DoFn
, if theprocess
method returns None, we can issue a warning, such asno iterator is returned by the process method in DoFn
. This could help users debug whether returning None is expected. Possible code changes could be in_check_fn_use_yield_and_return
from https://github.com/apache/beam/blob/master/sdks/python/apache_beam/transforms/core.py.Issue Priority
Priority: 3 (nice-to-have improvement)
Issue Components