xevion/indexer-analyze
1
0
Fork 0
mirror of https://github.com/Xevion/indexer-analyze.git synced 2025-12-05 23:15:18 -06:00
Code Issues Packages Projects Releases Wiki Activity

shutdown rps printer once series processing is done, rps 1 decimal

Browse Source
This commit is contained in:
Xevion
2025-06-01 03:23:12 -05:00
parent c55046c708
commit efcab62336
1 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
main.py
View File

@@ -203,8 +203,10 @@ async def main():
)
total_indexer_counts.update(indexer_counts)
async def print_rps(interval=3):
async def print_rps(interval=3, stop_event=None):
while True:
if stop_event and stop_event.is_set():
break
await anyio.sleep(interval)
async with counter_lock:
rps = request_counter["count"] / interval
@@ -212,15 +214,18 @@ async def main():
request_counter["count"] = 0
await logger.info(
"Requests per second and active requests",
rps=rps,
rps=round(rps, 1),
active_requests=active,
interval=interval,
)
stop_event = anyio.Event()
async with anyio.create_task_group() as tg:
tg.start_soon(print_rps, 3)
tg.start_soon(print_rps, 3, stop_event)
async with anyio.create_task_group() as series_tg:
for series in series_list:
tg.start_soon(process_and_log, series)
series_tg.start_soon(process_and_log, series)
stop_event.set()
await logger.info(
"Total indexer counts across all series",