def METHOD_NAME(self, msg, e):
    self._manager.ds_failure_handler(msg, e)
    if 'email' in msg:
        traceback = e.__cause__.traceback if isinstance(e.__cause__, ImzMLError) else None
        self._manager.send_failed_email(msg, traceback)
    self._redis_client.set('cluster-busy', 'no')