[Failing Test]: GroupBy example tests (groupby_test.py) fail

[hjtran]

What happened?

The test utility assert_that has to be run in a pipeline that hasn't been executed. Before #30771 it was easy to accidentally do it after a pipeline had already been executed which resulted in a test that would always pass.

After #30771 , it'll no longer be possible to do this. As a result, it turns out groupby_test.py's unit tests are always passing. I've skipped them temporarily

Issue Failure

Failure: Test is continually failing

Issue Priority

Priority: 2 (backlog / disabled test but we think the product is healthy)

Issue Components

• Component: Python SDK
• Component: Java SDK
• Component: Go SDK
• Component: Typescript SDK
• Component: IO connector
• Component: Beam YAML
• Component: Beam examples
• Component: Beam playground
• Component: Beam katas
• Component: Website
• Component: Spark Runner
• Component: Flink Runner
• Component: Samza Runner
• Component: Twister2 Runner
• Component: Hazelcast Jet Runner
• Component: Google Cloud Dataflow Runner

[github-actions]

This issue has been marked as stale due to 150 days of inactivity. It will be closed in 30 days if no further activity occurs. If you think that’s incorrect or this issue still needs to be addressed, please simply write any comment. If closed, you can reopen the issue at any time. Thank you for your contributions.

[alisha-1000]

@hjtran I’m interested in fixing this. I’ll refactor the GroupBy example tests so assert_that() is attached before pipeline execution (per #30771) and re-enable the currently skipped tests.

[alisha-1000]

.take_issue

[mtauha]

I'd like to work on this! Could you assign it to me @hjtran?