trending/pentagi
1
0
Fork 0
mirror of https://github.com/vxcontrol/pentagi.git synced 2026-10-02 01:44:31 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #323 from mrigankad/fix/installer-swallowed-gather-error

Browse Source 
fix(installer): propagate swallowed GatherUpdatesInfo errors
This commit is contained in:
Dmitry Ng
2026-05-31 12:49:55 +04:00
committed by GitHub
parent 4a9d706cfd 6bea1581f6
commit dc83cb6e50
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/cmd/installer/processor/logic.go
+10 -10
View File
@@ -149,8 +149,8 @@ func (p *processor) applyChanges(ctx context.Context, state *operationState) (er
return
}
// refresh state for updates
if err := p.checker.GatherUpdatesInfo(ctx); err != nil {
err = fmt.Errorf("failed to gather info after update: %w", err)
if gatherErr := p.checker.GatherUpdatesInfo(ctx); gatherErr != nil {
err = fmt.Errorf("failed to gather info after update: %w", gatherErr)
}
}()
@@ -446,8 +446,8 @@ func (p *processor) install(ctx context.Context, state *operationState) (err err
return
}
// refresh state for updates
if err := p.checker.GatherUpdatesInfo(ctx); err != nil {
err = fmt.Errorf("failed to gather info after update: %w", err)
if gatherErr := p.checker.GatherUpdatesInfo(ctx); gatherErr != nil {
err = fmt.Errorf("failed to gather info after update: %w", gatherErr)
}
}()
@@ -499,8 +499,8 @@ func (p *processor) update(ctx context.Context, stack ProductStack, state *opera
return
}
// refresh state for updates
if err := p.checker.GatherUpdatesInfo(ctx); err != nil {
err = fmt.Errorf("failed to gather info after update: %w", err)
if gatherErr := p.checker.GatherUpdatesInfo(ctx); gatherErr != nil {
err = fmt.Errorf("failed to gather info after update: %w", gatherErr)
}
}()
@@ -694,7 +694,7 @@ func (p *processor) remove(ctx context.Context, stack ProductStack, state *opera
return fmt.Errorf("failed to gather worker info after remove: %w", err)
}
if err := p.checker.GatherUpdatesInfo(ctx); err != nil {
err = fmt.Errorf("failed to gather info after update: %w", err)
return fmt.Errorf("failed to gather info after update: %w", err)
}
case ProductStackInstaller:
@@ -733,8 +733,8 @@ func (p *processor) purge(ctx context.Context, stack ProductStack, state *operat
return
}
// refresh state for updates
if err := p.checker.GatherUpdatesInfo(ctx); err != nil {
err = fmt.Errorf("failed to gather info after update: %w", err)
if gatherErr := p.checker.GatherUpdatesInfo(ctx); gatherErr != nil {
err = fmt.Errorf("failed to gather info after update: %w", gatherErr)
}
}()
@@ -774,7 +774,7 @@ func (p *processor) purge(ctx context.Context, stack ProductStack, state *operat
return fmt.Errorf("failed to gather worker info after purge: %w", err)
}
if err := p.checker.GatherUpdatesInfo(ctx); err != nil {
err = fmt.Errorf("failed to gather info after update: %w", err)
return fmt.Errorf("failed to gather info after update: %w", err)
}
case ProductStackInstaller: