update max_chunks for testing

Author: LuckyYC

backend/service/task_service.py

@@ -931,7 +931,7 @@ async def _handle_streaming_response(response, full_url: str) -> Dict:
             }
 
         # For testing purposes, we limit the time and data we collect
-        max_chunks = 50  # max chunks to collect for testing
+        max_chunks = 200  # max chunks to collect for testing
         max_duration = 15  # max duration to wait for testing
 
         start_time = asyncio.get_event_loop().time()

frontend/src/components/CreateJobForm.tsx

@@ -338,9 +338,39 @@ const CreateJobFormContent: React.FC<CreateJobFormProps> = ({
   const handleTestAPI = async () => {
     try {
       setTesting(true);
-      const values = await form.validateFields();
 
-      // Validate request payload for custom APIs
+      // Only validate required fields for testing, not API Field Mapping fields
+      const requiredFields = [
+        'target_host',
+        'api_path',
+        'model',
+        'duration',
+        'concurrent_users',
+        'stream_mode',
+      ];
+
+      // Get current api_path to determine API type
+      const currentApiPath = form.getFieldValue('api_path');
+      const isCurrentlyChatCompletions =
+        !currentApiPath || currentApiPath === '/v1/chat/completions';
+
+      // Add chat_type validation for chat completions API
+      if (isCurrentlyChatCompletions) {
+        requiredFields.push('chat_type');
+      }
+
+      // Add request_payload validation for custom APIs
+      if (!isCurrentlyChatCompletions) {
+        requiredFields.push('request_payload');
+      }
+
+      // Validate only the required fields for testing
+      await form.validateFields(requiredFields);
+
+      // Get all form values after validation
+      const values = form.getFieldsValue();
+
+      // Additional validation for request payload JSON format (custom APIs only)
       if (
         values.api_path !== '/v1/chat/completions' &&
         !values.request_payload

st_engine/engine/locustfile.py

@@ -1002,6 +1002,7 @@ def _handle_stream_request(
                 try:
                     # Process as streaming response
                     for chunk in response.iter_lines():
+                        task_logger.info(f"Chunk: {chunk}")
                         error_msg = StreamProcessor.check_chunk_error(
                             chunk, field_mapping, task_logger
                         )