Skip to content

Commit

Permalink
chore: skrLooper log field workerId (#356)
Browse files Browse the repository at this point in the history
  • Loading branch information
tmilos77 authored Jul 19, 2024
1 parent f18eb15 commit 1bb44e9
Showing 1 changed file with 6 additions and 4 deletions.
10 changes: 6 additions & 4 deletions pkg/skr/runtime/looper/skrLooper.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@ import (
"errors"
"github.com/elliotchance/pie/v2"
"github.com/go-logr/logr"
"github.com/kyma-project/cloud-manager/pkg/composed"
"github.com/kyma-project/cloud-manager/pkg/feature"
"github.com/kyma-project/cloud-manager/pkg/feature/types"
"github.com/kyma-project/cloud-manager/pkg/metrics"
Expand Down Expand Up @@ -201,9 +202,10 @@ func (l *skrLooper) handleOneSkr(skrWorkerId int, kymaName string) {
}()
logger := l.logger.WithValues(
"skrWorkerId", skrWorkerId,
"skrKymaName", kymaName,
"kyma", kymaName,
)
skrManager, scope, kyma, err := l.managerFactory.CreateManager(l.ctx, kymaName, logger)
ctx := composed.LoggerIntoCtx(l.ctx, logger)
skrManager, scope, kyma, err := l.managerFactory.CreateManager(ctx, kymaName, logger)
if errors.Is(err, &skrmanager.ScopeNotFoundError{}) {
logger.
WithValues("error", err.Error()).
Expand All @@ -218,12 +220,12 @@ func (l *skrLooper) handleOneSkr(skrWorkerId int, kymaName string) {
}
skrManager.GetScheme()

ctx := feature.ContextBuilderFromCtx(l.ctx).
ctx = feature.ContextBuilderFromCtx(ctx).
Landscape(os.Getenv("LANDSCAPE")).
LoadFromScope(scope).
LoadFromKyma(kyma).
Plane(types.PlaneSkr).
Build(l.ctx)
Build(ctx)

logger = feature.DecorateLogger(ctx, logger)

Expand Down

0 comments on commit 1bb44e9

Please sign in to comment.