def METHOD_NAME(self, query):
    res = self.execute_query_with_retries(query)
    if self._lineage_logger:
        lineage_data = self._get_lineage_data(query)
        if lineage_data:
            self._lineage_logger.send(lineage_data)
    #  TODO: collect lineage for failed query
    return res