Dask Performance Report

Select different tabs on the top for additional information

Duration: 1227.76 s

Tasks Information

• number of tasks: 6082
• compute time: 155410.24 s
• disk-read time: 9.38 ms
• transfer time: 993.00 s

Scheduler Information

• Address: tls://10.2.11.86:8786
• Workers: 50
• Threads: 200
• Memory: 800.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.