feat(executor_manager): increase default MAX_CONCURRENT_TASKS from 5 to 30 (#225)

Update the default maximum concurrent executor tasks to 30 for improved
parallel task processing capacity. Changes applied to:
- docker-compose.yml environment variable
- scheduler.py default fallback value
- routers.py load API default fallback value

Co-authored-by: qdaxb <4157870+qdaxb@users.noreply.github.com>

Author: qdaxb

docker-compose.yml

@@ -105,7 +105,7 @@ services:
     environment:
       - TZ=Asia/Shanghai
       - TASK_API_DOMAIN=http://backend:8000
-      - MAX_CONCURRENT_TASKS=5
+      - MAX_CONCURRENT_TASKS=30
       - PORT=8001
       - CALLBACK_HOST=http://executor_manager:8001
       - NETWORK=wegent-network

executor_manager/routers/routers.py

@@ -161,7 +161,7 @@ async def get_executor_load(http_request: Request):
         logger.info(f"Received request to get executor load from {client_ip}")
         executor = ExecutorDispatcher.get_executor(EXECUTOR_DISPATCHER_MODE)
         result = executor.get_executor_count()
-        result["total"] = int(os.getenv("MAX_CONCURRENT_TASKS", "5"))
+        result["total"] = int(os.getenv("MAX_CONCURRENT_TASKS", "30"))
         return result
     except Exception as e:
         logger.error(f"Error getting executor load: {e}")

executor_manager/scheduler/scheduler.py

@@ -42,7 +42,7 @@ def __init__(self):
         self.api_client = TaskApiClient()
         self.task_processor = TaskProcessor()
         self.running = False
-        self.max_concurrent_tasks = int(os.getenv("MAX_CONCURRENT_TASKS", "5"))
+        self.max_concurrent_tasks = int(os.getenv("MAX_CONCURRENT_TASKS", "30"))
         self.max_offline_concurrent_tasks = int(os.getenv("MAX_OFFLINE_CONCURRENT_TASKS", "10"))
 
         # Configure APScheduler