Ryan Thompson
Ryan Thompson
Run Python 3.7 PostCommit
Run Python 3.9 PostCommit
@tvalentyn This looks ready to merge, the failing test is not the new test I added but rather the issue described here: https://github.com/apache/beam/issues/22605
Run Python 3.9 PostCommit
Run Python 3.9 PostCommit
This looks fine, but I don't really understand how this fixes the issue. Can you explain that in the comments of the test? It's not really clear why we would...
R: @AnandInguva
@damccorm @AnandInguva Can you take a look. I made a bunch of changes to this PR.
R: tvalentyn I want to talk about this before I submit. The coGroupByKey implementation specifically does make a dictionary with a [Key to list pairing](https://github.com/apache/beam/blob/cebf7388fc7a63f138f194ec0ed39e882ebfc72c/sdks/python/apache_beam/transforms/util.py#L245). However, the documentation is very...