Dask Performance Report

Select different tabs on the top for additional information

Duration: 58.94 s

Tasks Information

• number of tasks: 5665
• compute time: 5200.25 s
• transfer time: 1079.61 s

Scheduler Information

• Address: tls://10.2.13.119:8786
• Workers: 45
• Threads: 180
• Memory: 720.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.