Dask Performance Report

Select different tabs on the top for additional information

Duration: 56.25 s

Tasks Information

  • number of tasks: 6083
  • compute time: 5205.60 s
  • deserialize time: 334.00 ms
  • transfer time: 963.38 s

Scheduler Information

  • Address: tls://10.2.13.119:8786
  • Workers: 48
  • Threads: 192
  • Memory: 768.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.

        
Summary
Task Stream
Worker Profile (compute)
Worker Profile (administrative)
Scheduler Profile (administrative)
Bandwidth (Workers)
Bandwidth (Types)