You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by yh...@apache.org on 2026/07/10 20:29:05 UTC
(beam) branch master updated: Fix Community Metrics Prober job (#39290)
This is an automated email from the ASF dual-hosted git repository.
Abacn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new cccb6494667 Fix Community Metrics Prober job (#39290)
cccb6494667 is described below
commit cccb64946675deeb2e77f9f3d5ced2ab63e4f6e2
Author: Vitaly Terentyev <vi...@gmail.com>
AuthorDate: Sat Jul 11 00:28:58 2026 +0400
Fix Community Metrics Prober job (#39290)
---
.test-infra/metrics/src/test/groovy/ProberTests.groovy | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/.test-infra/metrics/src/test/groovy/ProberTests.groovy b/.test-infra/metrics/src/test/groovy/ProberTests.groovy
index c5de9ca64c8..6f9befc2c20 100644
--- a/.test-infra/metrics/src/test/groovy/ProberTests.groovy
+++ b/.test-infra/metrics/src/test/groovy/ProberTests.groovy
@@ -22,12 +22,12 @@ import groovy.json.JsonSlurper
import static groovy.test.GroovyAssert.shouldFail
/**
- * Prober tests which performs health checks on deployed infrasture for
+ * Prober tests which performs health checks on deployed infrastructure for
* community metrics.
*/
class ProberTests {
// TODO: Make this configurable
- def grafanaEndpoint = 'http://metrics.beam.apache.org'
+ def grafanaEndpoint = 'https://metrics.beam.apache.org'
@Test
void PingGrafanaHttpApi() {
@@ -36,14 +36,14 @@ class ProberTests {
def dashboardNames = allDashboards.title
// Validate at least one expected dashboard exists
assert dashboardNames.contains('Post-commit Test Reliability') : 'Expected dashboard does not exist'
- assert dashboardNames.size > 0 : "No dashboards found. Check Grafana dashboard initialization script."
+ assert dashboardNames.size() > 0 : "No dashboards found. Check Grafana dashboard initialization script."
}
@Test
void CheckGrafanaStalenessAlerts() {
def alertsJson = "${grafanaEndpoint}/api/alerts?dashboardQuery=Source%20Data%20Freshness".toURL().text
def alerts = new JsonSlurper().parseText(alertsJson)
- assert alerts.size > 0
+ assert alerts.size() > 0
alerts.each { alert ->
assert alert.state == 'ok' : "Input data is stale! ${alert}\n See: ${grafanaEndpoint}/d/data-freshness"
}