@tenacity.retry(stop=tenacity.stop_after_attempt(3), wait=tenacity.wait_exponential(), reraise=True)
def read_pod_logs(self, pod: V1Pod, tail_lines: Optional[int]=None, timestamps: bool=False, since_seconds: Optional[int]=None):
    'Reads log from the POD'
    additional_kwargs = {}
    if since_seconds:
        additional_kwargs['since_seconds'] = since_seconds
    if tail_lines:
        additional_kwargs['tail_lines'] = tail_lines
    try:
        return self._client.read_namespaced_pod_log(name=pod.metadata.name, namespace=pod.metadata.namespace, container='base', follow=True, timestamps=timestamps, _preload_content=False, **additional_kwargs)
    except BaseHTTPError as e:
        raise AirflowException(f'There was an error reading the kubernetes API: {e}')
Reads log from the POD
@tenacity.retry(stop=tenacity.stop_after_attempt(3), wait=tenacity.wait_exponential(), reraise=True)
def read_pod_logs(self, pod: V1Pod, tail_lines: Optional[int]=None, timestamps: bool=False, since_seconds: Optional[int]=None):
    
    additional_kwargs = {}
    if since_seconds:
        additional_kwargs['since_seconds'] = since_seconds
    if tail_lines:
        additional_kwargs['tail_lines'] = tail_lines
    try:
        return self._client.read_namespaced_pod_log(name=pod.metadata.name, namespace=pod.metadata.namespace, container='base', follow=True, timestamps=timestamps, _preload_content=False, **additional_kwargs)
    except BaseHTTPError as e:
        raise AirflowException(f'There was an error reading the kubernetes API: {e}')