Skip to content

Commit d4939f7

Browse files
committed
Add Execution model
1 parent 47cfe36 commit d4939f7

File tree

2 files changed

+9
-5
lines changed

2 files changed

+9
-5
lines changed

plugins/kernels/fps_kernels/models.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,3 +32,8 @@ class Session(BaseModel):
3232
type: str
3333
kernel: Kernel
3434
notebook: Notebook
35+
36+
37+
class Execution(BaseModel):
38+
document_id: str
39+
cell_idx: int

plugins/kernels/fps_kernels/routes.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525
KernelServer,
2626
kernels,
2727
)
28-
from .models import Session
28+
from .models import Session, Execution
2929

3030
router = APIRouter()
3131

@@ -175,15 +175,14 @@ async def restart_kernel(
175175

176176
@router.post("/api/kernels/{kernel_id}/execute")
177177
async def execute_cell(
178-
request: Request,
178+
execution: Execution,
179179
kernel_id,
180180
user: UserRead = Depends(current_user),
181181
):
182-
r = await request.json()
183182
if kernel_id in kernels:
184-
room = YDocWebSocketHandler.websocket_server.get_room(r["document_id"])
183+
room = YDocWebSocketHandler.websocket_server.get_room(execution.document_id)
185184
nb = room.document.source
186-
cell = nb["cells"][int(r["cell_idx"])]
185+
cell = nb["cells"][execution.cell_idx]
187186
cell["outputs"] = []
188187

189188
kernel = kernels[kernel_id]

0 commit comments

Comments
 (0)