File: //lib/python3/dist-packages/cloudinit/sources/azure/__pycache__/kvp.cpython-310.pyc
o
x[hk � @ s� d dl Z d dlmZmZ d dlmZ d dlmZ d dlmZm Z d dl
m Z m Z e �
e�Zdeej fdd �Zd
edefd d �Zd
e jdefdd�Zdefdd�ZdS )� N)�datetime�timezone)�Optional)�version)�handlers� instantiated_handler_registry)�errors�identity�returnc C s t j�d�} t| tj�sdS | S )z'Get instantiated KVP telemetry handler.� telemetryN)r �registered_items�get�
isinstancer �HyperVKvpReportingHandler)� kvp_handler� r �=/usr/lib/python3/dist-packages/cloudinit/sources/azure/kvp.py�get_kvp_handler s � r �reportc C s, t � }|du rt�d� dS |�d| � dS )z/Report to host via PROVISIONING_REPORT KVP key.Nz.KVP handler not enabled, skipping host report.F�PROVISIONING_REPORTT)r �LOG�debug� write_key)r r r r r �report_via_kvp s
r �errorc C s t | �� �S )N)r �as_encoded_report)r r r r �report_failure_to_host& s r c
C sx zt �� } W n ty } z d|��} W Y d }~nd }~ww t�ddt�� � �dt�t j
�� � � �d| � �g�}t |�S )Nzfailed to read vm id: zresult=successzagent=Cloud-Init/z
timestamp=zvm_id=)
r � query_vm_id� Exceptionr �
encode_reportr �version_stringr �nowr �utc� isoformatr )�vm_id�id_errorr r r r �report_success_to_host* s �� �� r& )�loggingr r �typingr � cloudinitr �cloudinit.reportingr r �cloudinit.sources.azurer r � getLogger�__name__r r r �str�boolr �ReportableErrorr r& r r r r �<module> s