Kronecker/NotesAgentic
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 10 Wiki Activity

test: verify live chat agent MCP and task load flows

Browse Source
This commit is contained in:
admin
2026-09-06 23:25:17 +08:00
parent 12b732d936
commit aa8b631724
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/scripts/task-http-stress.py
+8 -3
View File
@@ -46,11 +46,15 @@ async def main(args):
timings[kind].append((perf_counter()-start)*1000) timings[kind].append((perf_counter()-start)*1000)
response.raise_for_status() response.raise_for_status()
return response.json() return response.json()
health_stop = asyncio.Event()
async def health(): async def health():
while True: while not health_stop.is_set():
try: await request('GET', '/health', 'health') try: await request('GET', '/health', 'health')
except httpx.HTTPError as error: errors.append(type(error).__name__) except httpx.HTTPError as error: errors.append(type(error).__name__)
await asyncio.sleep(.05) try:
await asyncio.wait_for(health_stop.wait(), timeout=.05)
except TimeoutError:
pass
heartbeat = asyncio.create_task(health()) heartbeat = asyncio.create_task(health())
start = perf_counter() start = perf_counter()
try: try:
@@ -72,7 +76,8 @@ async def main(args):
remaining = await request('GET', '/api/tasks', 'list') remaining = await request('GET', '/api/tasks', 'list')
assert remaining['page']['total'] == 0 assert remaining['page']['total'] == 0
finally: finally:
heartbeat.cancel(); await asyncio.gather(heartbeat, return_exceptions=True) health_stop.set()
await asyncio.wait_for(heartbeat, timeout=35)
report = {'transport': 'real loopback HTTP, separate Uvicorn process', 'tasks': args.count, report = {'transport': 'real loopback HTTP, separate Uvicorn process', 'tasks': args.count,
'concurrency': args.concurrency, 'elapsed_ms': round((perf_counter()-start)*1000, 2), 'concurrency': args.concurrency, 'elapsed_ms': round((perf_counter()-start)*1000, 2),
'latencies': {key: stats(value) for key,value in timings.items()}, 'health_errors': errors, 'latencies': {key: stats(value) for key,value in timings.items()}, 'health_errors': errors,