yangdx
commited on
Commit
·
b802259
1
Parent(s):
bca22a9
Remove Chinese comments and added English comments for clarity
Browse files
test_lightrag_ollama_chat.py
CHANGED
@@ -688,7 +688,6 @@ def test_generate_concurrent() -> None:
|
|
688 |
]
|
689 |
results = await asyncio.gather(*tasks, return_exceptions=True)
|
690 |
|
691 |
-
# 收集成功和失败的结果
|
692 |
success_results = []
|
693 |
error_messages = []
|
694 |
|
@@ -698,15 +697,12 @@ def test_generate_concurrent() -> None:
|
|
698 |
else:
|
699 |
success_results.append((i + 1, result))
|
700 |
|
701 |
-
# 如果有任何错误,在打印完所有结果后抛出异常
|
702 |
if error_messages:
|
703 |
-
# 先打印成功的结果
|
704 |
for req_id, result in success_results:
|
705 |
if OutputControl.is_verbose():
|
706 |
print(f"\nRequest {req_id} succeeded:")
|
707 |
print_json_response(result)
|
708 |
|
709 |
-
# 打印所有错误信息
|
710 |
error_summary = "\n".join(error_messages)
|
711 |
raise McpError(
|
712 |
ErrorCode.InternalError,
|
@@ -721,12 +717,12 @@ def test_generate_concurrent() -> None:
|
|
721 |
# Run concurrent requests
|
722 |
try:
|
723 |
results = asyncio.run(run_concurrent_requests())
|
724 |
-
#
|
725 |
for i, result in enumerate(results, 1):
|
726 |
print(f"\nRequest {i} result:")
|
727 |
print_json_response(result)
|
728 |
except McpError:
|
729 |
-
#
|
730 |
raise
|
731 |
|
732 |
|
|
|
688 |
]
|
689 |
results = await asyncio.gather(*tasks, return_exceptions=True)
|
690 |
|
|
|
691 |
success_results = []
|
692 |
error_messages = []
|
693 |
|
|
|
697 |
else:
|
698 |
success_results.append((i + 1, result))
|
699 |
|
|
|
700 |
if error_messages:
|
|
|
701 |
for req_id, result in success_results:
|
702 |
if OutputControl.is_verbose():
|
703 |
print(f"\nRequest {req_id} succeeded:")
|
704 |
print_json_response(result)
|
705 |
|
|
|
706 |
error_summary = "\n".join(error_messages)
|
707 |
raise McpError(
|
708 |
ErrorCode.InternalError,
|
|
|
717 |
# Run concurrent requests
|
718 |
try:
|
719 |
results = asyncio.run(run_concurrent_requests())
|
720 |
+
# all success, print out results
|
721 |
for i, result in enumerate(results, 1):
|
722 |
print(f"\nRequest {i} result:")
|
723 |
print_json_response(result)
|
724 |
except McpError:
|
725 |
+
# error message already printed
|
726 |
raise
|
727 |
|
728 |
|