liferoad commented on issue #35493:
URL: https://github.com/apache/beam/issues/35493#issuecomment-3067268385
Two thoughts (not tested since I am a Scala user):
1. possible to disable the type checking for your PythonExternalTransform?
2. You could try to convert the incoming schema objects to Row objects
within your transform:
```
import apache_beam as beam
from apache_beam.pvalue import Row
class MyTransform(beam.PTransform):
def expand(self, pcoll):
def convert_to_row(element):
if hasattr(element, '_fields'):
# Convert NamedTuple to Row
return Row(**element._asdict())
return element
return (
pcoll
| 'Convert to Row' >> beam.Map(convert_to_row)
| 'Your Logic' >> ...
)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
