Skip to content

Commit a7e6486

Browse files
committed
fixup! Concurrently retry taking over watcher
1 parent fa209c8 commit a7e6486

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

internal/pkg/agent/application/upgrade/upgrade.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -473,8 +473,8 @@ func (u *Upgrader) takeOverWatcher(ctx context.Context) (*filelock.AppLocker, er
473473
defer takeOverTicker.Stop()
474474
for {
475475
select {
476-
case err := <-takeoverCtx.Done():
477-
return nil, fmt.Errorf("taking over watcher applocker: %w", err)
476+
case <-takeoverCtx.Done():
477+
return nil, fmt.Errorf("timed out taking over watcher applocker")
478478
case <-takeOverTicker.C:
479479
locker := filelock.NewAppLocker(paths.Top(), "watcher.lock")
480480
err := locker.TryLock()

0 commit comments

Comments
 (0)