@tenacity.retry(stop=tenacity.stop_after_attempt(3), wait=tenacity.wait_exponential(), reraise=True)
def read_pod_events(self, pod):
    'Reads events from the POD'
    try:
        return self._client.list_namespaced_event(namespace=pod.metadata.namespace, field_selector=f'involvedObject.name={pod.metadata.name}')
    except BaseHTTPError as e:
        raise AirflowException(f'There was an error reading the kubernetes API: {e}')
Reads events from the POD
@tenacity.retry(stop=tenacity.stop_after_attempt(3), wait=tenacity.wait_exponential(), reraise=True)
def read_pod_events(self, pod):
    
    try:
        return self._client.list_namespaced_event(namespace=pod.metadata.namespace, field_selector=f'involvedObject.name={pod.metadata.name}')
    except BaseHTTPError as e:
        raise AirflowException(f'There was an error reading the kubernetes API: {e}')