Dask Performance Report

Select different tabs on the top for additional information

Duration: 680.34 s

Tasks Information

• number of tasks: 10515
• compute time: 15153.85 s
• deserialize time: 2.69 s
• disk-read time: 109.79 s
• disk-write time: 5.50 s
• transfer time: 4404.07 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.