ska_sdp_batchlet.utils.monitor.dask_monitor module

ska_sdp_batchlet.utils.monitor.dask_monitor.dask_monitor(report_dir, scheduler_address, generate_reports_on_failure=True)[source]

Dask performance monitor is responsible for monitoring the system resources (CPU, Memory) on single/multi-node system, while the subprocess command is running. It uses ska-sdp-benchmark-monitor for resource monitoring. This function should be called with "with".

Parameters:

  • report_dir (str) -- Directory to save the report.

  • scheduler_address (str) -- Dask cluster address.

  • generate_reports_on_failure (bool) -- Whether to generate reports even if some exception occurs during exit