liferoad commented on PR #36251: URL: https://github.com/apache/beam/pull/36251#issuecomment-3328534404
> > 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 > ``` Added one check for that. -- 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]
