def _es_call(self, cmd, *args, **kwargs): try: return getattr(self._es, cmd)(*args, **kwargs) except ElasticsearchException as e: self._log_error(e) return None