admovdz commented on issue #29116:
URL: https://github.com/apache/beam/issues/29116#issuecomment-1778802143
Hello,
A workaround waiting for support response :
```python
# The Taggedoutput have to have same is_bounded state like the source
initial_get_item = DoOutputsTuple.__getitem__
def new_get_item(self: DoOutputsTuple, tag: int | str | None):
tag_not_in_pcolls = tag not in self._pcolls
pcoll = initial_get_item(self, tag)
if tag_not_in_pcolls:
assert self.producer is not None
pval = self.producer.parts[0].outputs[None]
# pass bounded state
pcoll.is_bounded = pval.is_bounded
return pcoll
DoOutputsTuple.__getitem__ = new_get_item
```
--
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]
