def METHOD_NAME(self, failure_message):
    _logger.error(failure_message, extra={'capture': False})
    self.kill_workers()
    self.report_worker_error_logs()
    get_xmlrpc_proxy(config.root.parallel.server_addr, self.server.port).report_session_error(failure_message)
    raise ParallelTimeout(failure_message)