def METHOD_NAME(self, resource_version, timeout=5):
    stream = self.k8s_api.get_host_definition_stream(resource_version, timeout)
    for watch_event in stream:
        watch_event = utils.munch(watch_event)
        host_definition_info = self.resource_info_manager.generate_host_definition_info(watch_event.object)
        if self.host_definition_manager.is_host_definition_in_pending_phase(host_definition_info.phase) and \
                not utils.is_watch_object_type_is_delete(watch_event.type):
            self._define_host_definition_after_pending_state(host_definition_info)