def METHOD_NAME(self, *args, **kwargs):
    status = self.query_region('status')
    last_loaded_data = get_not_null(status['status'], 'last_rt_data_loaded')
    item = self._make_mock_item(*args, **kwargs)
    self._publish(item)
    # we sleep a bit to let kraken reload the data
    self._poll_until_reload(last_loaded_data)