DirectRunner assert_that should work in user state and timers tests
Open
core
improvement
P3
python
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 1d 20h
- Merged PRs (30d)
- 196
Description
In the DirectRunner, the assert_that transform does not work in all cases for streaming execution, especially in the user state and timers tests, so a workaround is used in this case. We should fix this.
Imported from Jira [BEAM-5295](https://issues.apache.org/jira/browse/BEAM-5295). Original Jira may contain additional context.
Reported by: ccy.
Contributor guide
Research direction
Start with the DirectRunner's streaming execution and the assert_that transform, then inspect the user state and timers tests mentioned in the issue to understand the current workaround. Done means assert_that works in those tests without the workaround.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java, python
- Domain
- stream-processing, testing
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 35/100