core.monitor

class core.monitor.Chrono(name='chrono object', unit='m')

Bases: object

• name: str

• unit “m” | “s” | “ms” | “us”

display(unit: Literal['m', 's', 'ms', 'us'] = None)

elapsed() → timedelta

laps() → timedelta

pause()

reset() → timedelta

restart()

stop() → timedelta

class core.monitor.MemHist(tickrate: int = 5)

Bases: object

class core.monitor.Monitor(name: str = 'monitor object', time: Chrono = None, ram: RAM = None)

Bases: object

Meta-structure to monitor some variables in a script

display()

elapsed()

laps()

pause()

reset()

restart()

stop()

class core.monitor.RAM(name='ram object')

Bases: object

• name: str

display()

elapsed()

laps()

pause()

reset()

restart()

stop()

core.monitor.dask_graph_stats(ds) → DataFrame

Get statistics about the dask graph for each variable in the dataset ds.

Returns a pandas DataFrame with the following columns:

• var: The name of the variable.

• graph_len: The length of the dask graph for the variable.

• n_chunks: The number of chunks in the dask graph for the variable.

• per_chunk: graph_len/n_chunks.

Example: >>> print(dask_graph_stats(ds).to_string(index=False))

core.monitor.ram_probe(pid: int, period: float, stop_event, result_queue: Queue)