Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
Description
def my_function(element):
...
pcoll | beam.FlatMap(my_function)
now has a stage name of FlatMap(<lambda at core.py:2027>) rather than FlatMap(my_function). Not sure when this regression was introduced.
Attachments
Issue Links
- links to