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"
     }