(maven-dist-tool) branch use_json_jenkins_api updated: limit concurrency call

[olamy]

This is an automated email from the ASF dual-hosted git repository.

olamy pushed a commit to branch use_json_jenkins_api
in repository https://gitbox.apache.org/repos/asf/maven-dist-tool.git


The following commit(s) were added to refs/heads/use_json_jenkins_api by this 
push:
     new 1b50ba5  limit concurrency call
1b50ba5 is described below

commit 1b50ba558b03e3700fc83a233c2f9609190285ed
Author: Olivier Lamy <ol...@apache.org>
AuthorDate: Sun Mar 15 12:09:18 2026 +1000

    limit concurrency call
    
    Signed-off-by: Olivier Lamy <ol...@apache.org>
---
 .../maven/dist/tools/jobs/AbstractJobsReport.java      |  4 ++++
 .../dist/tools/jobs/master/ListMasterJobsReport.java   | 18 ++++++++++--------
 2 files changed, 14 insertions(+), 8 deletions(-)

diff --git 
a/src/main/java/org/apache/maven/dist/tools/jobs/AbstractJobsReport.java 
b/src/main/java/org/apache/maven/dist/tools/jobs/AbstractJobsReport.java
index 3b5bd9d..eb7e0c6 100644
--- a/src/main/java/org/apache/maven/dist/tools/jobs/AbstractJobsReport.java
+++ b/src/main/java/org/apache/maven/dist/tools/jobs/AbstractJobsReport.java
@@ -26,6 +26,7 @@ import java.util.List;
 import java.util.stream.Collectors;
 
 import org.apache.maven.dist.tools.JsoupRetry;
+import org.apache.maven.plugins.annotations.Parameter;
 import org.apache.maven.reporting.AbstractMavenReport;
 import org.apache.maven.reporting.MavenReportException;
 import org.jsoup.nodes.Document;
@@ -35,6 +36,9 @@ import org.jsoup.select.Elements;
 public abstract class AbstractJobsReport extends AbstractMavenReport {
     protected static final String GITBOX_URL = 
"https://gitbox.apache.org/repos/asf";;
 
+    @Parameter(defaultValue = "8", property = "dist-tool.jobs.concurrency")
+    protected int concurrency;
+
     protected static final String MAVENBOX_JOBS_BASE_URL = 
"https://ci-maven.apache.org/job/Maven/job/maven-box/job/";;
 
     private static final Collection<String> EXCLUDED = Arrays.asList(
diff --git 
a/src/main/java/org/apache/maven/dist/tools/jobs/master/ListMasterJobsReport.java
 
b/src/main/java/org/apache/maven/dist/tools/jobs/master/ListMasterJobsReport.java
index 9c6666e..92b9b17 100644
--- 
a/src/main/java/org/apache/maven/dist/tools/jobs/master/ListMasterJobsReport.java
+++ 
b/src/main/java/org/apache/maven/dist/tools/jobs/master/ListMasterJobsReport.java
@@ -77,14 +77,16 @@ public class ListMasterJobsReport extends 
AbstractJobsReport {
         Collection<String> repositoryNames = repositoryNames();
 
         List<Result> repoStatus = Flux.fromIterable(repositoryNames)
-                .flatMap(repo -> JsonRetry.getAsync(MAVENBOX_JOBS_BASE_URL + 
repo
-                                + 
"/api/json?tree=jobs[name,url,color,lastBuild[result,number]]")
-                        .flatMap(jsonNode -> buildResult(repo, jsonNode))
-                        .onErrorResume(e -> {
-                            getLog().warn("Failed to read status for " + repo 
+ " Jenkins job " + MAVENBOX_JOBS_BASE_URL
-                                    + repo);
-                            return Mono.empty();
-                        }))
+                .flatMap(
+                        repo -> JsonRetry.getAsync(MAVENBOX_JOBS_BASE_URL + 
repo
+                                        + 
"/api/json?tree=jobs[name,url,color,lastBuild[result,number]]")
+                                .flatMap(jsonNode -> buildResult(repo, 
jsonNode))
+                                .onErrorResume(e -> {
+                                    getLog().warn("Failed to read status for " 
+ repo + " Jenkins job "
+                                            + MAVENBOX_JOBS_BASE_URL + repo);
+                                    return Mono.empty();
+                                }),
+                        concurrency)
                 .collectList()
                 .block();