Skip to content

Commit 76145c0

Browse files
committed
Decrease the worker progress update interval
Maybe we should make this configurable or adaptable in some way. For now I prefer to have fast updates.
1 parent 57c8ea4 commit 76145c0

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

cmd/bonanza_scheduler/main.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,7 @@ func main() {
165165
ExecutionUpdateInterval: time.Minute,
166166
OperationWithNoWaitersTimeout: time.Minute,
167167
PlatformQueueWithNoWorkersTimeout: platformQueueWithNoWorkersTimeout.AsDuration(),
168-
BusyWorkerSynchronizationInterval: 10 * time.Second,
168+
BusyWorkerSynchronizationInterval: 2 * time.Second,
169169
GetIdleWorkerSynchronizationInterval: func() time.Duration {
170170
// Let synchronization calls block somewhere
171171
// between 0 and 2 minutes. Add jitter to

pkg/model/evaluation/executor.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -417,7 +417,7 @@ func (e *executor) Execute(ctx context.Context, action *model_executewithstorage
417417
// Launch a goroutine for reporting progress.
418418
dependenciesGroup.Go(func(ctx context.Context, siblingsGroup, dependenciesGroup program.Group) error {
419419
for {
420-
t, tChan := e.clock.NewTimer(10 * time.Second)
420+
t, tChan := e.clock.NewTimer(2 * time.Second)
421421
select {
422422
case <-ctx.Done():
423423
t.Stop()

0 commit comments

Comments
 (0)