Skip to content

Code Interpreter healthcheck endpoint + ready command #164

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
wants to merge 3 commits into
base: main
Choose a base branch
from
Draft

Code Interpreter healthcheck endpoint + ready command #164

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
aee3565
added healthcheck for default web sockets
mishushakov Oct 31, 2025
2c0289d
updated readycmd
mishushakov Oct 31, 2025
98184c9
web sockets not ready until they are
mishushakov Oct 31, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions template/e2b.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@
team_id = "460355b3-4f64-48f9-9a16-4442817f79f5"
memory_mb = 1_024
start_cmd = "/root/.jupyter/start-up.sh"
ready_cmd = "curl -sf http://localhost:49999/health"
dockerfile = "e2b.Dockerfile"
template_name = "code-interpreter-v1"
template_id = "nlhz8vlwyupq845jsdg9"
11 changes: 10 additions & 1 deletion template/server/main.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,16 @@ async def lifespan(app: FastAPI):

@app.get("/health")
async def get_health():
return "OK"
websockets_ready = False
for ws in default_websockets.values():
Copy link

@cursor cursor bot Oct 31, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Bug: Race Condition in Health Check Iteration

The health check has a race condition. It iterates over default_websockets.values() without acquiring a lock, while default_websockets (a LockedMap) is modified concurrently elsewhere. This can lead to inconsistent health check results or iteration exceptions.

Fix in Cursor Fix in Web

if ws in websockets and websockets[ws].is_connected():
websockets_ready = True
break

if not websockets_ready:
return PlainTextResponse("Not ready", status_code=503)

return PlainTextResponse("OK", status_code=200)


@app.post("/execute")
Expand Down
4 changes: 4 additions & 0 deletions template/server/messaging.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -542,6 +542,10 @@ async def _process_message(self, data: dict):
else:
logger.warning(f"[UNHANDLED MESSAGE TYPE]: {data['msg_type']}")

def is_connected(self) -> bool:
"""Check if the websocket is connected and open"""
return self._ws is not None and self._ws.open

async def close(self):
logger.debug(f"Closing WebSocket {self.context_id}")

Expand Down