-
Notifications
You must be signed in to change notification settings - Fork 115
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
go/worker/executor: update scheduling parameters on runtime updates #3222
Conversation
0740aa0
to
b5bfd0c
Compare
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.
Some minor nits, otherwise looks good!
// XXX: Once there is more than one scheduling algorithm available | ||
// this might need to recreate the scheduler and reinsert | ||
// the transactions. | ||
// At that point also udpate the schedulerMutex usage across the |
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.
// At that point also udpate the schedulerMutex usage across the | |
// At that point also update the schedulerMutex usage across the |
Algorithm: "invalid", | ||
}, | ||
) | ||
require.Error(t, err, "UpdateParameters invalid udpate") | ||
|
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.
Remove empty line?
// Make sure transaction doesn't get scheduled. | ||
err = scheduler.Flush(false) | ||
require.NoError(t, err, "Flush(force=false)") | ||
require.Equal(t, 1, scheduler.UnscheduledSize(), "transaction should remain scheduled after a non-forced flush") |
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.
require.Equal(t, 1, scheduler.UnscheduledSize(), "transaction should remain scheduled after a non-forced flush") | |
require.Equal(t, 1, scheduler.UnscheduledSize(), "transaction should remain unscheduled after a non-forced flush") |
@@ -14,7 +16,6 @@ const ( | |||
) | |||
|
|||
type scheduler struct { | |||
cfg config |
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.
Should we also remove the config
type?
.changelog/3203.bugfix.md
Outdated
@@ -0,0 +1,4 @@ | |||
Executor scheduling doesn't refresh runtime parameters |
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.
Executor scheduling doesn't refresh runtime parameters | |
Executor should refresh runtime scheduling parameters |
b5bfd0c
to
45ca039
Compare
Codecov Report
@@ Coverage Diff @@
## master #3222 +/- ##
==========================================
- Coverage 67.47% 67.30% -0.18%
==========================================
Files 370 370
Lines 36323 36343 +20
==========================================
- Hits 24509 24460 -49
- Misses 8648 8703 +55
- Partials 3166 3180 +14
Continue to review full report at Codecov.
|
Fixes: #3203