GaetanLepage commented on PR #36251:
URL: https://github.com/apache/beam/pull/36251#issuecomment-3327390970
> I did more checks. Please help validate this. Thanks.
```
self =
<apache_beam.pipeline.Pipeline.to_runner_api.<locals>.ForceKvInputTypes object
at 0x7ffddbed8ec0>
transform_node = AppliedPTransform(assert_that/Create/MaybeReshuffle,
MaybeReshuffle)
def visit_transform(self, transform_node):
# type: (AppliedPTransform) -> None
if not transform_node.transform:
return
> if transform_node.transform.runner_api_requires_keyed_input():
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
E AttributeError: 'MaybeReshuffle' object has no attribute
'runner_api_requires_keyed_input'
apache_beam/pipeline.py:1026: AttributeError
```
--
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]
