New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Bug 1502044 - add buffer size and work_engine test #510
Conversation
| ft.AssertEqual(t, we.bufsz, 10) | ||
| } | ||
|
|
||
| func TestGetActiveTopics(t *testing.T) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🎉 👍
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
| ft.AssertEqual(t, "invalid work topic", err.Error(), "invalid error") | ||
| } | ||
|
|
||
| func TestStartNewJob(t *testing.T) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This function still needed?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@rthallisey I changed that test to actually do the test I was expecting. Should work now.
pkg/broker/work_engine_test.go
Outdated
|
|
||
| func (mw mockWorker) Run(token string, buffer chan<- WorkMsg) { | ||
| fmt.Println("xxxxxxxxxxxxxxxxxxxxx run called") | ||
| mw.called = true |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The code where this gets used is commented out. Does TestStartNewJob need to be uncommented or should we remove the mockWorker struct?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I'll clean that up. I think I wsa in the middle of creating a test that didn't quite work because I needed to mock something else.
during a refactoring of the work engines to support async deprovision and update we missed the buffer size.
during a refactoring of the work engines to support async deprovision
and update we missed the buffer size.
Which issue this PR fixes (This will close that issue when PR gets merged)
fixes 1502044