def METHOD_NAME(self, req, client_address):
    if isinstance(req, HostsUpdatedRequest):
        self._manager.handle_hosts_updated(req.timestamp, req.res)
        return network.AckResponse()
    return super(WorkerNotificationService, self).METHOD_NAME(req, client_address)