fix: improve progress tracking with non-linear progress calculation

- Add calculate_nonlinear_progress() utility function using exponential decay curve
- Replace linear time-based progress with non-linear progress in VeCPCRBuilder and VeAgentkitRuntimeRunner
- Increase VeCPCRBuilder max wait time from 600s to 900s (10 to 15 minutes)
- Set expected_time to 30s to control progress curve speed (faster initial progress)
- Cap progress at 95% before task completion to avoid premature 100% display

(cherry picked from commit 8142443a29f354f9c5aff957e7c1adda93aae4b7)

Author: innsd

agentkit/toolkit/builders/ve_pipeline.py

@@ -26,7 +26,7 @@
 from agentkit.toolkit.models import BuildResult, ImageInfo
 from agentkit.toolkit.reporter import Reporter
 from agentkit.toolkit.errors import ErrorCode
-from agentkit.utils.misc import generate_random_id
+from agentkit.utils.misc import generate_random_id, calculate_nonlinear_progress
 from agentkit.toolkit.volcengine.services import CRServiceConfig
 from .base import Builder
 
@@ -1056,8 +1056,9 @@ def download_and_show_logs(run_id: str):
             self.reporter.info("Waiting for build completion...")
 
             # Wait for build completion using reporter's long task interface
-            max_wait_time = 600  # 10 minutes
+            max_wait_time = 900  # 15 minutes
             check_interval = 3  # Check every 3 seconds
+            expected_time = 30  # Controls progress curve speed (smaller = faster initial progress)
             import time
             start_time = time.time()
 
@@ -1098,8 +1099,7 @@ def download_and_show_logs(run_id: str):
                                 download_and_show_logs(run_id)
                                 raise Exception(error_msg)
 
-                            # Update progress (time-based)
-                            task.update(completed=min(elapsed_time, max_wait_time))
+                            task.update(completed=calculate_nonlinear_progress(elapsed_time, max_wait_time, expected_time))
                             time.sleep(check_interval)
                         else:
                             # Unknown status
@@ -1111,8 +1111,7 @@ def download_and_show_logs(run_id: str):
                                 download_and_show_logs(run_id)
                                 raise Exception(error_msg)
 
-                            # Update progress
-                            task.update(completed=min(elapsed_time, max_wait_time))
+                            task.update(completed=calculate_nonlinear_progress(elapsed_time, max_wait_time, expected_time))
                             time.sleep(check_interval)
 
                     except Exception:

agentkit/toolkit/config/utils.py

@@ -49,4 +49,4 @@ def merge_runtime_envs(common_config: Any, strategy_config: Dict[str, Any]) -> D
     if isinstance(strategy_level_envs, dict):
         merged_envs.update(strategy_level_envs)
 
-    return merged_envs
+    return merged_envs

agentkit/toolkit/resources/templates/golang/Dockerfile.j2

@@ -1,4 +1,4 @@
-# Build stage - 支持自定义构建镜像
+# Build stage - Support custom image
 {% if base_image_builder %}
 FROM {{ base_image_builder }} AS builder
 {% else %}
@@ -25,7 +25,6 @@ ENV GO_VERSION=1.24 \
 # download modules if go.mod present
 RUN if [ -f go.mod ]; then go mod download; fi
 
-# 执行自定义构建脚本（如需安装编译依赖、证书等）
 {% if build_script %}
 RUN chmod +x {{ build_script }} && /bin/sh {{ build_script }}
 {% endif %}
@@ -40,7 +39,7 @@ RUN mkdir -p ${BUILD_OUTPUT_DIR} && /bin/sh {{ entry_relative_path }}
 RUN mkdir -p ${BUILD_OUTPUT_DIR} && CGO_ENABLED=0 GOOS=linux go build -a -installsuffix cgo -o ${BUILD_OUTPUT_DIR}/${BUILD_BINARY_NAME} {{ entry_relative_path }}
 {% endif %}
 
-# Runtime stage - 支持自定义运行时镜像
+# Runtime stage - Support custom image
 {% if base_image_runtime %}
 FROM {{ base_image_runtime }}
 {% else %}

agentkit/toolkit/resources/templates/python/Dockerfile.j2

@@ -1,4 +1,4 @@
-# 支持自定义基础镜像
+# Support custom base image
 {% if base_image %}
 FROM {{ base_image }}
 {% else %}
@@ -20,7 +20,6 @@ RUN {% if dependencies_file %}{% if dependencies_install_path %}uv pip install {
     {% endif %}{% endif %}
 {% endif %}
 
-# 执行自定义构建脚本（如需安装系统依赖、编译C扩展等）
 {% if build_script %}
 COPY {{ build_script }} /tmp/build_script.sh
 RUN chmod +x /tmp/build_script.sh && /tmp/build_script.sh && rm /tmp/build_script.sh

agentkit/toolkit/runners/ve_agentkit.py

@@ -26,7 +26,7 @@
 from agentkit.toolkit.models import DeployResult, InvokeResult, StatusResult
 from agentkit.toolkit.reporter import Reporter
 from agentkit.toolkit.errors import ErrorCode
-from agentkit.utils.misc import generate_runtime_name, generate_runtime_role_name, generate_apikey_name, generate_client_token
+from agentkit.utils.misc import generate_runtime_name, generate_runtime_role_name, generate_apikey_name, generate_client_token, calculate_nonlinear_progress
 from agentkit.sdk.runtime.client import AgentkitRuntimeClient
 import agentkit.sdk.runtime.types as runtime_types
 
@@ -594,6 +594,7 @@ def _wait_for_runtime_status_multiple(
         last_status = None
         start_time = time.time()
         total_time = timeout if timeout else 300  # For progress bar display
+        expected_time = 30  # Controls progress curve speed (smaller = faster initial progress)
         runtime = None  # Initialize runtime variable
 
         # Use reporter.long_task() for progress tracking
@@ -625,8 +626,8 @@ def _wait_for_runtime_status_multiple(
                     task.update(description=f"Runtime status: {runtime.status}")
                     last_status = runtime.status
 
-                # Update progress
-                task.update(completed=min(elapsed_time, total_time))
+                # Update progress using non-linear curve
+                task.update(completed=calculate_nonlinear_progress(elapsed_time, total_time, expected_time))
 
                 time.sleep(3)
 

agentkit/utils/misc.py

@@ -12,6 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+import math
 import string
 import random
 
@@ -67,4 +68,37 @@ def generate_client_token() -> str:
     Returns:
         16位随机字符串
     """
-    return generate_random_id(16)
+    return generate_random_id(16)
+
+
+def calculate_nonlinear_progress(
+    elapsed: float, 
+    max_time: float, 
+    expected_time: float = 30.0,
+    max_ratio: float = 0.95
+) -> float:
+    """Calculate non-linear progress using exponential decay curve.
+    
+    This creates a progress bar that advances quickly at first, then slows down
+    as it approaches completion. Useful for tasks with unpredictable duration.
+    
+    Formula: progress = max_time * (1 - e^(-elapsed/expected_time))
+    
+    Example progress at different times (with expected_time=30):
+        - At 30s:  ~63%
+        - At 60s:  ~86%
+        - At 90s:  ~95%
+    
+    Args:
+        elapsed: Elapsed time in seconds.
+        max_time: Maximum time (used as progress bar total).
+        expected_time: Expected completion time, controls curve speed.
+            Smaller = faster initial progress.
+        max_ratio: Maximum progress ratio before task completes (default 0.95).
+            Prevents reaching 100% until task actually finishes.
+    
+    Returns:
+        Progress value between 0 and max_time * max_ratio.
+    """
+    progress = max_time * (1 - math.exp(-elapsed / expected_time))
+    return min(progress, max_time * max_ratio)