def _extract_xcom(self, pod: V1Pod):
    resp = kubernetes_stream(self._client.connect_get_namespaced_pod_exec, pod.metadata.name, pod.metadata.namespace, container=PodDefaults.SIDECAR_CONTAINER_NAME, command=['/bin/sh'], stdin=True, stdout=True, stderr=True, tty=False, _preload_content=False)
    try:
        result = self._exec_pod_command(resp, f'cat {PodDefaults.XCOM_MOUNT_PATH}/return.json')
        self._exec_pod_command(resp, 'kill -s SIGINT 1')
    finally:
        resp.close()
    if (result is None):
        raise AirflowException(f'Failed to extract xcom from pod: {pod.metadata.name}')
    return result
def _extract_xcom(self, pod: V1Pod):
    resp = kubernetes_stream(self._client.connect_get_namespaced_pod_exec, pod.metadata.name, pod.metadata.namespace, container=PodDefaults.SIDECAR_CONTAINER_NAME, command=['/bin/sh'], stdin=True, stdout=True, stderr=True, tty=False, _preload_content=False)
    try:
        result = self._exec_pod_command(resp, f'cat {PodDefaults.XCOM_MOUNT_PATH}/return.json')
        self._exec_pod_command(resp, 'kill -s SIGINT 1')
    finally:
        resp.close()
    if (result is None):
        raise AirflowException(f'Failed to extract xcom from pod: {pod.metadata.name}')
    return result