* action: added ActionLogContext.maxProcessTime(duration)

Signed-off-by: neo <[email protected]>

Author: neowu

CHANGELOG.md

@@ -8,6 +8,8 @@
   > migrated to apache httpclient 5   
   > simplify logging
   > remove opentelemetry dependency
+* action: added ActionLogContext.maxProcessTime(duration)
+  > for long and non-critical action (such as test jobs), set max process time to avoid SLOW_PROCESS warning
 
 ### 9.1.8 (3/7/2025 - 4/24/2025)
 

core-ng/src/main/java/core/framework/internal/web/sse/ServerSentEventHandler.java

@@ -62,8 +62,8 @@ public void handleRequest(HttpServerExchange exchange) {
             if (sink.flush()) {
                 exchange.dispatch(() -> handle(exchange, sink));
             } else {
-                var listener = ChannelListeners.flushingChannelListener(channel -> exchange.dispatch(() -> handle(exchange, sink)),
-                    (channel, e) -> {
+                var listener = ChannelListeners.flushingChannelListener(_ -> exchange.dispatch(() -> handle(exchange, sink)),
+                    (_, e) -> {
                         logger.warn("failed to establish sse connection, error={}", e.getMessage(), e);
                         IoUtils.safeClose(exchange.getConnection());
                     });

core-ng/src/main/java/core/framework/log/ActionLogContext.java

@@ -66,6 +66,14 @@ public static void triggerTrace(boolean cascade) {
         }
     }
 
+    // for non-critical actions, set max process time to avoid slow_process warning
+    public static void maxProcessTime(Duration duration) {
+        ActionLog actionLog = LogManager.CURRENT_ACTION_LOG.get();
+        if (actionLog != null) {
+            actionLog.warningContext.maxProcessTimeInNano(duration.toNanos());
+        }
+    }
+
     // for long process, use this guidance to determine whether continue to do more work
     @Nullable
     public static Duration remainingProcessTime() {

core-ng/src/test/java/core/framework/log/ActionLogContextTest.java

@@ -1,6 +1,5 @@
 package core.framework.log;
 
-import core.framework.internal.log.ActionLog;
 import core.framework.internal.log.LogManager;
 import core.framework.internal.log.Trace;
 import org.junit.jupiter.api.Test;
@@ -59,9 +58,9 @@ void remainingProcessTime() {
         assertThat(ActionLogContext.remainingProcessTime()).isNull();
 
         var logManager = new LogManager();
-        ActionLog log = logManager.begin("begin", null);
-        log.warningContext.maxProcessTimeInNano(Duration.ofSeconds(30).toNanos());
-        assertThat(ActionLogContext.remainingProcessTime()).isGreaterThan(Duration.ZERO);
+        logManager.begin("begin", null);
+        ActionLogContext.maxProcessTime(Duration.ofMinutes(30));
+        assertThat(ActionLogContext.remainingProcessTime()).isGreaterThan(Duration.ofMinutes(20));
         logManager.end("end");
     }
 }