diff --git a/go/oasis-test-runner/cmd/cmp/cmp.go b/go/oasis-test-runner/cmd/cmp/cmp.go index 0237aa66ea7..594bf52e627 100644 --- a/go/oasis-test-runner/cmd/cmp/cmp.go +++ b/go/oasis-test-runner/cmd/cmp/cmp.go @@ -120,7 +120,7 @@ func getDuration(ctx context.Context, test string, bi *model.SampleStream) (floa query := fmt.Sprintf("%s %s == 1.0", metrics.MetricUp, bi.Metric.String()) result, warnings, err := v1api.QueryRange(ctx, query, r) if err != nil { - nodeCommon.EarlyLogAndExit(fmt.Errorf("error querying Prometheus: %w", err)) + return 0, 0, fmt.Errorf("error querying Prometheus: %w", err) } if len(warnings) > 0 { cmpLogger.Warn("warnings while querying Prometheus", "warnings", warnings) @@ -206,7 +206,7 @@ func getSummableMetric(ctx context.Context, metric string, test string, bi *mode result, warnings, err := v1api.Query(ctx, query, t) if err != nil { - nodeCommon.EarlyLogAndExit(fmt.Errorf("error querying Prometheus: %w", err)) + return 0, 0, fmt.Errorf("error querying Prometheus: %w", err) } if len(warnings) > 0 { cmpLogger.Warn("warnings while querying Prometheus", "warnings", warnings) @@ -256,7 +256,7 @@ func getNetwork(ctx context.Context, test string, bi *model.SampleStream) (float query := fmt.Sprintf("(%s %s)", rxtx, labels.String()) result, warnings, err := v1api.QueryRange(ctx, query, r) if err != nil { - nodeCommon.EarlyLogAndExit(fmt.Errorf("error querying Prometheus: %w", err)) + return 0, 0, fmt.Errorf("error querying Prometheus: %w", err) } if len(warnings) > 0 { cmpLogger.Warn("warnings while querying Prometheus", "warnings", warnings)