ruạṛ
a �u:j< � @ s� d dl Z d dlZd dlZd dlZd dlmZ d dlmZmZ d dl m Z e dkrXe � � dd� Z dd � Ze� ste e _d Zd Zd d � ZdS )� N)�get_cbs_endpoint)�cbs_callback_uuid_context� cbs_custom_callback_url_context)� LogPrinter�__main__c O s, d� dd� | D ��}t�d�}|�|� d S )N� c s s | ]}t |�V qd S )N)�str)�.0�arg� r �F/opt/bart/bart_venv/lib/python3.9/site-packages/app/utils/callbacks.py� <genexpr> � z logger_print.<locals>.<genexpr>�bart)�join�logging� getLogger�info)�args�kwargs�message�loggerr r r � logger_print s r c C s t dkS )Nr )�__name__r r r r �is_running_as_cli s r � � c C sN t � � d�}t�� r"t�� � d�}t| �|||d�d�}t�� }|sRt�d� d S dd| � d|� �d�}tdtd �D ]�}zTt� d |� d |� �� t j |||d �} t� d | j � d | j �� � �� | �� W d S t j�yF } z\t�d|� d| � �� |tk �r(t| } t� d| � d�� t�| � n t�d� W Y d } ~ qvd } ~ 0 0 qvd S )Nz/v1/cbs/callback)� action_name� action_status� action_data)Zjob_id�dataz!UUID not found in request contextr �:)zX-CBS-Platformz X-CBS-BrandzX-CBS-Secret-Key� zCallback to CBS (Attempt z): )�json�headerszResponse from CBS: z - zAttempt z failed to call CBS callback: zRetrying after z seconds...z#All retries to CBS callback failed.)r r �get�intr r �error�range� MAX_RETRIESr �requests�post� status_code�text�strip�raise_for_status�RequestException�warn�RETRY_BACKOFF_SECONDS�time�sleep) Z cbs_job_idr r r Z callback_url�payloadZ uuid_secretr$ �attempt�response�eZ sleep_timer r r �call_cbs_callback# s> �� � r9 )�builtinsr r3 r* Z app.configr Zapp.utils.request_contextr r Zapp.utils.utility_functionsr r Zenable_loggingr r �printr) r2 r9 r r r r �<module> s
cải xoăn