-
Notifications
You must be signed in to change notification settings - Fork 177
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
github action for installing goka #373
Conversation
ff11c84
to
3800bb2
Compare
3800bb2
to
c64c2be
Compare
ff3b9d6
to
6a20b55
Compare
return proc1.Run(ctx) | ||
// simulatenously stopping multiple processors sometimes fails the processors, so this one gets delayed | ||
// see issue #376 for details | ||
return proc1.Run(DelayedCtxCloser(ctx, 5*time.Second)) |
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.
workaround to make the test more stable: avoid shutting down the processors simultaneously
|
||
err = tm.EnsureStreamExists(inputStream, 1) | ||
test.AssertNil(t, err) | ||
require.NoError(t, err) |
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 test was flaky altogether, because it created the wrong topic, which ended up with two topics having two different number of partitions, as the examples-cluster was configured with "auto-create:true". This is fixed now and yields two new issues:
- fix all examples that depend on "auto-create:true" (create actions for examples #379)
- detect partition mismatches (check partition mismatch #378)
6a20b55
to
06a6eaa
Compare
06a6eaa
to
0618db7
Compare
This PR improves testing of goka
testify