Working version
This commit is contained in:
@@ -133,8 +133,8 @@ async def get_status(uuid: str) -> VmStatusResponse:
|
|||||||
|
|
||||||
@router.get("/api/vms/{uuid}/logs")
|
@router.get("/api/vms/{uuid}/logs")
|
||||||
async def get_logs(uuid: str) -> StreamingResponse:
|
async def get_logs(uuid: str) -> StreamingResponse:
|
||||||
|
# Generator function that yields log lines as they are available
|
||||||
def stream_logs():
|
def stream_logs():
|
||||||
|
|
||||||
task = get_task(uuid)
|
task = get_task(uuid)
|
||||||
|
|
||||||
for proc in task.procs:
|
for proc in task.procs:
|
||||||
|
|||||||
Reference in New Issue
Block a user