Dask Performance Report

Select different tabs on the top for additional information

Duration: 733.56 s

Tasks Information

• number of tasks: 16488
• compute time: 15198.64 s
• disk-read time: 215.94 s
• disk-write time: 8.38 s
• transfer time: 5505.88 s

Scheduler Information

• Address: tls://10.2.12.7:8786
• Workers: 25
• Threads: 25
• Memory: 400.00 GB

Calling Code

    def _run(self):
        try:
            self._context.run(self._callback, *self._args)
        except (SystemExit, KeyboardInterrupt):
            raise
        except BaseException as exc:
            cb = format_helpers._format_callback_source(
                self._callback, self._args)
            msg = f'Exception in callback {cb}'
            context = {
                'message': msg,
                'exception': exc,
                'handle': self,
            }
            if self._source_traceback:
                context['source_traceback'] = self._source_traceback
            self._loop.call_exception_handler(context)
        self = None  # Needed to break cycles when an exception occurs.