mirror of
https://github.com/exo-explore/exo.git
synced 2026-02-26 03:06:05 -05:00
Compare commits
1 Commits
nid-persis
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
ba611f9cd0 |
@@ -542,13 +542,10 @@ class InfoGatherer:
|
||||
if not p.stdout:
|
||||
logger.critical("MacMon closed stdout")
|
||||
return
|
||||
t = TextReceiveStream(BufferedByteReceiveStream(p.stdout))
|
||||
while True:
|
||||
with anyio.fail_after(self.macmon_interval * 3):
|
||||
macmon_output = await t.receive()
|
||||
await self.info_sender.send(
|
||||
MacmonMetrics.from_raw_json(macmon_output)
|
||||
)
|
||||
async for text in TextReceiveStream(
|
||||
BufferedByteReceiveStream(p.stdout)
|
||||
):
|
||||
await self.info_sender.send(MacmonMetrics.from_raw_json(text))
|
||||
except CalledProcessError as e:
|
||||
stderr_msg = "no stderr"
|
||||
stderr_output = cast(bytes | str | None, e.stderr)
|
||||
@@ -559,12 +556,8 @@ class InfoGatherer:
|
||||
else str(stderr_output)
|
||||
)
|
||||
logger.warning(
|
||||
f"memory monitor failed with return code {e.returncode}: {stderr_msg}"
|
||||
)
|
||||
except TimeoutError:
|
||||
logger.warning(
|
||||
f"memory monitor silent for {self.macmon_interval * 3}s - reloading"
|
||||
f"MacMon failed with return code {e.returncode}: {stderr_msg}"
|
||||
)
|
||||
except Exception as e:
|
||||
logger.opt(exception=e).warning("Error in memory monitor")
|
||||
logger.warning(f"Error in macmon monitor: {e}")
|
||||
await anyio.sleep(self.macmon_interval)
|
||||
|
||||
Reference in New Issue
Block a user