yujunjun/ragflow
1
0
Fork 0
mirror of https://github.com/infiniflow/ragflow.git synced 2025-12-01 01:16:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix: code executor timeout (#9671)

Browse Source 
### What problem does this PR solve?

Code executor timeout.

### Type of change

- [x] Bug Fix (non-breaking change which fixes an issue)
This commit is contained in:
Yongteng Lei 2025-08-22 19:31:49 +08:00 committed by GitHub
parent cc167ae619
commit 035e8ed0f7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
agent/tools/code_exec.py
View File

@ -79,7 +79,7 @@ def main() -> dict:
return { return {
"result": fibonacci_recursive(100), "result": fibonacci_recursive(100),
} }
Here's a code example for Javascript(`main` function MUST be included and exported): Here's a code example for Javascript(`main` function MUST be included and exported):
const axios = require('axios'); const axios = require('axios');
async function main(args) { async function main(args) {
@ -156,7 +156,7 @@ class CodeExec(ToolBase, ABC):
self.set_output("_ERROR", "construct code request error: " + str(e)) self.set_output("_ERROR", "construct code request error: " + str(e))
try: try:
resp = requests.post(url=f"http://{settings.SANDBOX_HOST}:9385/run", json=code_req, timeout=10) resp = requests.post(url=f"http://{settings.SANDBOX_HOST}:9385/run", json=code_req, timeout=os.environ.get("COMPONENT_EXEC_TIMEOUT", 10*60))
logging.info(f"http://{settings.SANDBOX_HOST}:9385/run", code_req, resp.status_code) logging.info(f"http://{settings.SANDBOX_HOST}:9385/run", code_req, resp.status_code)
if resp.status_code != 200: if resp.status_code != 200:
resp.raise_for_status() resp.raise_for_status()

3
sandbox/executor_manager/core/config.py
View File

@ -22,7 +22,7 @@ from util import format_timeout_duration, parse_timeout_duration
from core.container import init_containers, teardown_containers from core.container import init_containers, teardown_containers
from core.logger import logger from core.logger import logger
TIMEOUT = 10 TIMEOUT = parse_timeout_duration(os.getenv("SANDBOX_TIMEOUT", "10s"))
@asynccontextmanager @asynccontextmanager
@ -39,6 +39,5 @@ async def _lifespan(app: FastAPI):
def init(): def init():
TIMEOUT = parse_timeout_duration(os.getenv("SANDBOX_TIMEOUT"))
logger.info(f"Global timeout: {format_timeout_duration(TIMEOUT)}") logger.info(f"Global timeout: {format_timeout_duration(TIMEOUT)}")
return _lifespan return _lifespan