(beam) branch master updated: Fix cancelled run handling in flaky test prefetcher (#38579)

[yhu]

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 889ac54b236 Fix cancelled run handling in flaky test prefetcher 
(#38579)
889ac54b236 is described below

commit 889ac54b236b26b689b3f1856167bf4302c47afa
Author: Abdelrahman Ibrahim <abdoibrahim1...@gmail.com>
AuthorDate: Fri May 22 19:06:10 2026 +0200

    Fix cancelled run handling in flaky test prefetcher (#38579)
    
    Co-authored-by: Cursor <cursorag...@cursor.com>
---
 .test-infra/metrics/sync/github/github_runs_prefetcher/code/main.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/.test-infra/metrics/sync/github/github_runs_prefetcher/code/main.py 
b/.test-infra/metrics/sync/github/github_runs_prefetcher/code/main.py
index 044866813fa..76d8e488bce 100644
--- a/.test-infra/metrics/sync/github/github_runs_prefetcher/code/main.py
+++ b/.test-infra/metrics/sync/github/github_runs_prefetcher/code/main.py
@@ -182,7 +182,7 @@ async def check_workflow_flakiness(workflow):
 
     success_rate = 1.0
     if len(workflow_runs):
-        failed_runs = list(filter(lambda r: r.status == "failure" | r.status 
== "cancelled", workflow_runs))
+        failed_runs = list(filter(lambda r: r.status == "failure" or r.status 
== "cancelled", workflow_runs))
         print(f"Number of failed workflow runs: {len(failed_runs)}")
         success_rate -= len(failed_runs) / len(workflow_runs)