Skip to content

Commit d7eae7d

Browse files
committed
[supervisor] Mimic changes from 9b3f8a2
1 parent d8a5388 commit d7eae7d

File tree

1 file changed

+3
-3
lines changed
  • components/supervisor/pkg/supervisor

1 file changed

+3
-3
lines changed

components/supervisor/pkg/supervisor/top.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -51,15 +51,15 @@ func (t *TopService) Observe(ctx context.Context) {
5151
go func() {
5252
for {
5353
data, err := t.top(ctx)
54-
if err != nil {
55-
log.WithField("error", err).Errorf("failed to retrieve resource status from upstream, trying again in %d seconds...", uint32(delay.Seconds()))
56-
} else {
54+
if err == nil {
5755
delay = minReconnectionDelay
5856
t.data = data
5957

6058
t.readyOnce.Do(func() {
6159
close(t.ready)
6260
})
61+
} else if ctx.Err() == nil {
62+
log.WithField("error", err).Errorf("failed to retrieve resource status from upstream, trying again in %d seconds...", uint32(delay.Seconds()))
6363
}
6464
select {
6565
case <-ctx.Done():

0 commit comments

Comments
 (0)