Current Dir: /snap/core22/2955/usr/lib/python3/dist-packages/cloudinit/sources/azure/__pycache__/
[FILE] errors.cpython-310.pyc [ edit | delete | rename ]
[FILE] identity.cpython-310.pyc [ edit | delete | rename ]
[FILE] imds.cpython-310.pyc [ edit | delete | rename ]
[FILE] kvp.cpython-310.pyc [ edit | delete | rename ]
[FILE] __init__.cpython-310.pyc [ edit | delete | rename ]
Viewing: /snap/core22/2955/usr/lib/python3/dist-packages/cloudinit/sources/azure/__pycache__/errors.cpython-310.pyc
o
� �i � @ s� d dl Z d dlZd dlZd dlZd dlmZmZ d dlmZ d dlm Z m
Z
m Z m Z m
Z
d dlmZ d dlZd dlmZmZ d dlmZ e�e�Z d,d
e e d ed ed
efdd�ZG dd� de �Z G dd� de �Z G dd� de �Z G dd� de �Z G dd� de �Z!G dd� de �Z"G d d � d e �Z#G d d � d e �Z$G d d!� d!e �Z%G d"d#� d#e �Z&G d$d%� d%e �Z'G d&d'� d'e �Z(G d(d)� d)e �Z)G d*d+� d+e �Z*dS )-� N)�datetime�timezone)�StringIO)�Any�Dict�List�Optional�Tuple)� ElementTree)�subp�version)�UrlError�|�'�data� delimiter� quotechar�returnc C sP t � �}tj|||tjd��| � |�� �� W d � S 1 s!w Y dS )z Encode report data with csv.)r r �quotingN)r �csv�writer�
QUOTE_MINIMAL�writerow�getvalue�rstrip)r r r �io� r �@/usr/lib/python3/dist-packages/cloudinit/sources/azure/errors.py�
encode_report s �
$�r c @ sf e Zd Zdd�dedeeeef ddfdd�Zdee defd d
�Zde fd d �Z
defd
d�Z dS )�ReportableErrorN)�supporting_data�reasonr r c C s@ dt �� � �| _d| _|| _|r|| _ni | _t�tj �| _
d S )Nz Cloud-Init/z%https://aka.ms/linuxprovisioningerror) r �version_string�agent�documentation_urlr! r r �nowr �utc� timestamp)�selfr! r r r r �__init__' s zReportableError.__init__�vm_idc C sb dd| j � �d| j� �g}|dd� | j�� D �7 }|d|� �d| j�� � �d| j� �g7 }t|�S ) Nz result=errorzreason=zagent=c S s g | ] \}}|� d |� ��qS )�=r )�.0�k�vr r r �
<listcomp>? s z5ReportableError.as_encoded_report.<locals>.<listcomp>zvm_id=z
timestamp=zdocumentation_url=)r! r# r �itemsr' � isoformatr$ r )r( r* r r r r �as_encoded_report5 s
�
�z!ReportableError.as_encoded_reportc C s. t |t�o| j|jko| j|jko| j|jkS )N)�
isinstancer r' r! r )r( �otherr r r �__eq__H s
�
�
�zReportableError.__eq__c C s& | j j� d| j� d| j� d| j� d�S )Nz(reason=z , timestamp=z, supporting_data=�))� __class__�__name__r! r' r �r( r r r �__repr__P s
����zReportableError.__repr__) r8 �
__module__� __qualname__�strr r r r) r2 �boolr5 r: r r r r r & s ���
��
�r c �& e Zd Zdeddf� fdd� Z� ZS )�$ReportableErrorDhcpInterfaceNotFound�durationr Nc s t � �d� || jd< d S )Nz failure to find DHCP interfacerA ��superr) r )r( rA �r7 r r r) Z s z-ReportableErrorDhcpInterfaceNotFound.__init__)r8 r; r< �floatr) �
__classcell__r r rD r r@ Y � r@ c
s> e Zd Zdee dedee dee ddf
� fdd� Z� ZS ) �ReportableErrorDhcpLease�driverrA � interface� mac_addressr Nc s8 t � �d� || jd< || jd< || jd< || jd< d S )Nz failure to obtain DHCP leaserI rA rJ rK rB )r( rI rA rJ rK rD r r r) a s
z!ReportableErrorDhcpLease.__init__)r8 r; r< r r= rE r) rF r r rD r rH ` s �����rH c sZ e Zd Zdee dee dee deeeeef deeef ddf � fdd � Z � Z
S )
�(ReportableErrorDhcpOnNonPrimaryInterfacerJ rI �router�
static_routes�leaser Nc sB t � �d� || jd< || jd< || jd< || jd< || jd< d S )Nz&failure to find primary DHCP interfacerJ rI rM rN rO rB )r( rJ rI rM rN rO rD r r r) q s
z1ReportableErrorDhcpOnNonPrimaryInterface.__init__) r8 r; r< r r= r r r r r) rF r r rD r rL p s ����
��rL c �* e Zd Zdededdf� fdd� Z� ZS )�ReportableErrorImdsUrlError� exceptionrA r Nc s� t |jtj�r
d}n!t |jtj�rd}nt |jtj�r d}n
|jr)d|j� d�}nd}t� �|� |jr:|j| j d< || j d< t
|�| j d < |j | j d
< d S ) Nz connection timeout querying IMDSz connection error querying IMDSzread timeout querying IMDSz http error z querying IMDSz unexpected error querying IMDS� http_coderA rR �url) r3 �cause�requests�ConnectTimeout�ConnectionError� ReadTimeout�coderC r) r �reprrT )r( rR rA r! rD r r r) � s
z$ReportableErrorImdsUrlError.__init__)r8 r; r< r
rE r) rF r r rD r rQ � � "rQ c rP )�"ReportableErrorImdsInvalidMetadata�key�valuer Nc s: t � �d|� �� || jd< || jd< t|�j| jd< d S )Nz invalid IMDS metadata for key=r^ r_ �type)rC r) r r` r8 )r( r^ r_ rD r r r) � s
z+ReportableErrorImdsInvalidMetadata.__init__)r8 r; r< r= r r) rF r r rD r r] � r\ r] c r? )�+ReportableErrorImdsMetadataParsingExceptionrR r Nc s t � �d� t|�| jd< d S )Nzerror parsing IMDS metadatarR �rC r) r[ r �r( rR rD r r r) � s z4ReportableErrorImdsMetadataParsingException.__init__)r8 r; r< �
ValueErrorr) rF r r rD r ra � rG ra c � e Zd Zd� fdd� Z� ZS )� ReportableErrorOsDiskPpsFailurer Nc � t � �d� d S )Nz error waiting for host shutdown�rC r) r9 rD r r r) � � z(ReportableErrorOsDiskPpsFailure.__init__�r N�r8 r; r< r) rF r r rD r rf � � rf c r? )�!ReportableErrorOvfInvalidMetadata�messager Nc s t � �d|� �� d S )Nz)unexpected metadata parsing ovf-env.xml: rh )r( rn rD r r r) � s z*ReportableErrorOvfInvalidMetadata.__init__)r8 r; r< r= r) rF r r rD r rm � rG rm c �( e Zd Zdejddf� fdd� Z� ZS )�"ReportableErrorOvfParsingExceptionrR r Nc s |j }t� �d|� �� d S )Nzerror parsing ovf-env.xml: )�msgrC r) )r( rR rn rD r r r) � s z+ReportableErrorOvfParsingException.__init__)r8 r; r< �ET�
ParseErrorr) rF r r rD r rp � � rp c r? )�!ReportableErrorUnhandledExceptionrR r Nc sz t � �d� d�t�t|�||j��}|�d�}|d d d� }d�|�}t� |�
d��� d�}t |�| j
d< || j
d< d S )Nzunhandled exception� �
���zutf-8rR �traceback_base64)rC r) �join� traceback�format_exceptionr` �
__traceback__�split�base64� b64encode�encode�decoder[ r )r( rR �trace� trace_lines�reversed_trace_lines�reversed_trace� trace_base64rD r r r) � s ��
�z*ReportableErrorUnhandledException.__init__)r8 r; r< � Exceptionr) rF r r rD r ru � rG ru c re )�!ReportableErrorProxyAgentNotFoundr Nc rg )Nzazure-proxy-agent not foundrh r9 rD r r r) � ri z*ReportableErrorProxyAgentNotFound.__init__rj rk r r rD r r� � rl r� c ro )�&ReportableErrorProxyAgentStatusFailurerR r Nc s4 t � �d� |j| jd< |j| jd< |j| jd< d S )Nz azure-proxy-agent status failure� exit_code�stdout�stderr)rC r) r� r r� r� rc rD r r r) � s z/ReportableErrorProxyAgentStatusFailure.__init__)r8 r; r< r �ProcessExecutionErrorr) rF r r rD r r� � rt r� c s4 e Zd Zdd�dedee ddf� fdd�Z� ZS )� ReportableErrorVmIdentificationN)� system_uuidrR r� r c s( t � �d� t|�| jd< || jd< d S )Nz failure to identify Azure VM IDrR r� rb )r( rR r� rD r r r) � s z(ReportableErrorVmIdentification.__init__)r8 r; r< r� r r= r) rF r r rD r r� � s ����r� )r r )+r r �loggingr{ r r r r �typingr r r r r � xml.etreer
rr rV � cloudinitr r �cloudinit.url_helperr
� getLoggerr8 �LOGr= r r� r r@ rH rL rQ r] ra rf rm rp ru r� r� r� r r r r �<module> sH
����
�3