diff options
| author | Paul Buetow <paul@buetow.org> | 2026-03-02 09:38:36 +0200 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2026-03-02 09:38:36 +0200 |
| commit | 5e8d0454d1aa5388a7045bdcb3069e41e4474957 (patch) | |
| tree | 8d12e2e7629ea8ec1b7efbe5a0fb022163f727dd /internal/mapr | |
| parent | d8d7e7c229e44bbd3a9d0ac268829e40d0704957 (diff) | |
mapr client: replace runtime panics with errors
Task: 4e6d7744-3f5c-4880-9e5d-368ece96470d
Diffstat (limited to 'internal/mapr')
| -rw-r--r-- | internal/mapr/client/aggregate.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/internal/mapr/client/aggregate.go b/internal/mapr/client/aggregate.go index 2e9b61a..2750643 100644 --- a/internal/mapr/client/aggregate.go +++ b/internal/mapr/client/aggregate.go @@ -67,7 +67,7 @@ func (a *Aggregate) Aggregate(message string) error { // Merge data from group into global group. isMerged, err := a.globalGroup.MergeNoblock(a.query, a.group) if err != nil { - panic(err) + return fmt.Errorf("unable to merge aggregate data for server %s: %w", a.server, err) } if isMerged { // Re-init local group (make it empty again). |