mirror of
https://github.com/meta-llama/llama-stack.git
synced 2025-08-06 18:50:44 +00:00
chore: Make code interpreter async
This commit is contained in:
parent
37f155e41d
commit
2d80153126
1 changed files with 3 additions and 2 deletions
|
@ -5,6 +5,7 @@
|
||||||
# the root directory of this source tree.
|
# the root directory of this source tree.
|
||||||
|
|
||||||
|
|
||||||
|
import asyncio
|
||||||
import logging
|
import logging
|
||||||
import os
|
import os
|
||||||
import tempfile
|
import tempfile
|
||||||
|
@ -37,7 +38,7 @@ class CodeInterpreterToolRuntimeImpl(ToolsProtocolPrivate, ToolRuntime):
|
||||||
async def initialize(self):
|
async def initialize(self):
|
||||||
pass
|
pass
|
||||||
|
|
||||||
async def register_tool(self, tool: Tool):
|
async def register_tool(self, tool: Tool) -> None:
|
||||||
pass
|
pass
|
||||||
|
|
||||||
async def unregister_tool(self, tool_id: str) -> None:
|
async def unregister_tool(self, tool_id: str) -> None:
|
||||||
|
@ -65,7 +66,7 @@ class CodeInterpreterToolRuntimeImpl(ToolsProtocolPrivate, ToolRuntime):
|
||||||
# Use environment variable to control bwrap usage
|
# Use environment variable to control bwrap usage
|
||||||
force_disable_bwrap = os.environ.get("DISABLE_CODE_SANDBOX", "").lower() in ("1", "true", "yes")
|
force_disable_bwrap = os.environ.get("DISABLE_CODE_SANDBOX", "").lower() in ("1", "true", "yes")
|
||||||
req = CodeExecutionRequest(scripts=[script], use_bwrap=not force_disable_bwrap)
|
req = CodeExecutionRequest(scripts=[script], use_bwrap=not force_disable_bwrap)
|
||||||
res = self.code_executor.execute(req)
|
res = await asyncio.to_thread(self.code_executor.execute, req)
|
||||||
pieces = [res["process_status"]]
|
pieces = [res["process_status"]]
|
||||||
for out_type in ["stdout", "stderr"]:
|
for out_type in ["stdout", "stderr"]:
|
||||||
res_out = res[out_type]
|
res_out = res[out_type]
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue