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.