diff --git a/theodolite/src/main/kotlin/theodolite/evaluation/AnalysisExecutor.kt b/theodolite/src/main/kotlin/theodolite/evaluation/AnalysisExecutor.kt index be3e48be406b631e03ca2fd32909a442b592f259..b3cc174d2945bf13bc1cc29d4e60d8c9bfbaf7eb 100644 --- a/theodolite/src/main/kotlin/theodolite/evaluation/AnalysisExecutor.kt +++ b/theodolite/src/main/kotlin/theodolite/evaluation/AnalysisExecutor.kt @@ -38,7 +38,7 @@ class AnalysisExecutor( try { val ioHandler = IOHandler() - val resultsFolder: String = ioHandler.getResultFolderURL() + val resultsFolder = ioHandler.getResultFolderURL() val fileURL = "${resultsFolder}exp${executionId}_${load.get()}_${res.get()}_${slo.sloType.toSlug()}" val prometheusData = executionIntervals diff --git a/theodolite/src/main/kotlin/theodolite/evaluation/MetricFetcher.kt b/theodolite/src/main/kotlin/theodolite/evaluation/MetricFetcher.kt index e54d79fe0f95b9f6079bd4295a74e81250b73a90..29f660b670e27e6b7c2fa7e769d5d3bf2919d989 100644 --- a/theodolite/src/main/kotlin/theodolite/evaluation/MetricFetcher.kt +++ b/theodolite/src/main/kotlin/theodolite/evaluation/MetricFetcher.kt @@ -45,10 +45,11 @@ class MetricFetcher(private val prometheusURL: String, private val offset: Durat ) while (counter < RETRIES) { + logger.info { "Request collected metrics from Prometheus for interval [$offsetStart,$offsetEnd]." } val response = get("$prometheusURL/api/v1/query_range", params = parameter, timeout = TIMEOUT) if (response.statusCode != 200) { val message = response.jsonObject.toString() - logger.warn { "Could not connect to Prometheus: $message. Retrying now." } + logger.warn { "Could not connect to Prometheus: $message. Retry $counter/$RETRIES." } counter++ } else { val values = parseValues(response)