diff --git a/enterprise/tailnet/pgcoord.go b/enterprise/tailnet/pgcoord.go index 367df51976572..b55868db8e175 100644 --- a/enterprise/tailnet/pgcoord.go +++ b/enterprise/tailnet/pgcoord.go @@ -639,7 +639,7 @@ func (m *mapper) run() { m.logger.Debug(m.ctx, "skipping nil node update") continue } - if err := m.c.Enqueue(update); err != nil { + if err := m.c.Enqueue(update); err != nil && !xerrors.Is(err, context.Canceled) { m.logger.Error(m.ctx, "failed to enqueue node update", slog.Error(err)) } } diff --git a/tailnet/coordinator.go b/tailnet/coordinator.go index bd1441e3a34a0..c200c5b21154a 100644 --- a/tailnet/coordinator.go +++ b/tailnet/coordinator.go @@ -810,7 +810,7 @@ func v1RespLoop(ctx context.Context, cancel context.CancelFunc, logger slog.Logg continue } err = q.Enqueue(nodes) - if err != nil { + if err != nil && !xerrors.Is(err, context.Canceled) { logger.Error(ctx, "v1RespLoop failed to enqueue v1 update", slog.Error(err)) } }