Yavook.de/kiwi-simple-metrics
1
0
Fork 0
mirror of https://github.com/yavook/kiwi-simple-metrics.git synced 2024-11-21 23:32:59 +00:00
Code Issues Projects Releases Packages Wiki Activity

minor last fix-ups

Browse source
This commit is contained in:
Jörn-Michael Miehe 2023-09-02 14:33:38 +00:00
parent 4f67c6158d
commit 4205b04b05
2 changed files with 12 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
kiwi_simple_metrics/main.py
View file

@ -44,15 +44,17 @@ def run_metrics(
async def async_main_loop() -> None: async def async_main_loop() -> None:
loop = asyncio.get_running_loop() loop = asyncio.get_running_loop()
while True: with concurrent.futures.ThreadPoolExecutor(
with concurrent.futures.ThreadPoolExecutor( max_workers=SETTINGS.threads,
max_workers=SETTINGS.threads, ) as pool:
) as pool: while True:
# start interval and metrics at the same time
await asyncio.gather( await asyncio.gather(
asyncio.sleep(SETTINGS.interval), asyncio.sleep(SETTINGS.interval),
loop.run_in_executor( loop.run_in_executor(
None, run_metrics, None, run_metrics,
pool, pool,
# metrics are reported in this order
metrics.cpu, metrics.cpu,
metrics.memory, metrics.memory,
metrics.disk, metrics.disk,

6
kiwi_simple_metrics/settings/metric.py
View file

@ -93,3 +93,9 @@ class ExternalMS(MetricSettings):
# wait at most this many seconds for each executable # wait at most this many seconds for each executable
timeout: int = 60 timeout: int = 60
@field_validator("count", mode="after")
@classmethod
def force_none(cls, _) -> int | None:
"""Don't accept a `count` value for the external metric!"""
return None