clan/clan-core
12
4
Fork 18
Code Issues 99 Pull Requests 3 Actions Packages Projects 1 Releases Wiki Activity

Completely working log streaming

Browse Source
This commit is contained in:
Luis Hebendanz 2023-09-27 02:27:53 +02:00 committed by Mic92
parent 8d390af122
commit 08eab785c6
2 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pkgs/clan-cli/clan_cli/webui/routers/vms.py
View File

@ -144,11 +144,12 @@ async def get_logs(uuid: str) -> StreamingResponse:
yield line + "\n"
for line in proc.stdout:
yield line + "\n"
break
continue
while True:
out = proc.output
line = out.get()
if line is None:
log.debug("stream logs and line is None")
break
yield line

11
pkgs/clan-cli/tests/test_vms_api.py
View File

@ -40,10 +40,17 @@ def test_create(api: TestClient, test_flake_with_core: Path) -> None:
assert response.status_code == 200, "Failed to get vm status"
response = api.get(f"/api/vms/{uuid}/logs")
print("=========LOGS==========")
print("=========FLAKE LOGS==========")
for line in response.stream:
assert line != b"", "Failed to get vm logs"
print(line.decode("utf-8"), end="")
print("=========END LOGS==========")
assert response.status_code == 200, "Failed to get vm logs"
response = api.get(f"/api/vms/{uuid}/logs")
print("=========VM LOGS==========")
for line in response.stream:
assert line != b"", "Failed to get vm logs"
print(line.decode("utf-8"), end="")
print("=========END LOGS==========")
assert response.status_code == 200, "Failed to get vm logs"
time.sleep(10)