feat(agent): do not block execution of controllers on error
arcad/emissary/pipeline/head Something is wrong with the build of this commit
Details
arcad/emissary/pipeline/head Something is wrong with the build of this commit
Details
This commit is contained in:
parent
7d551a8312
commit
909549f056
|
@ -44,8 +44,6 @@ func (a *Agent) Run(ctx context.Context) error {
|
||||||
|
|
||||||
if err := a.registerAgent(ctx, client, state); err != nil {
|
if err := a.registerAgent(ctx, client, state); err != nil {
|
||||||
logger.Error(ctx, "could not register agent", logger.E(errors.WithStack(err)))
|
logger.Error(ctx, "could not register agent", logger.E(errors.WithStack(err)))
|
||||||
|
|
||||||
return
|
|
||||||
}
|
}
|
||||||
|
|
||||||
logger.Debug(ctx, "state before reconciliation", logger.F("state", state))
|
logger.Debug(ctx, "state before reconciliation", logger.F("state", state))
|
||||||
|
@ -81,7 +79,7 @@ func (a *Agent) Reconcile(ctx context.Context, state *State) error {
|
||||||
)
|
)
|
||||||
|
|
||||||
if err := ctrl.Reconcile(ctrlCtx, state); err != nil {
|
if err := ctrl.Reconcile(ctrlCtx, state); err != nil {
|
||||||
return errors.WithStack(err)
|
logger.Error(ctx, "could not reconcile", logger.E(errors.WithStack(err)))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue