File: //usr/lib/python3/dist-packages/boto/services/__pycache__/submit.cpython-310.pyc
o
ckF[�
� @ s$ d dl Z d dlZG dd� de�ZdS )� Nc @ s8 e Zd Zdd� Zdd� Zdd� Zdd
d �Zdd
d�ZdS )� Submitterc C sB || _ | j �d�| _| j �d�| _| j �d�| _| j �d�| _d S )N� input_bucket�
output_bucket�
output_domain� input_queue)�sd�get_objr r r �queue)�selfr � r �6/usr/lib/python3/dist-packages/boto/services/submit.py�__init__ s
zSubmitter.__init__c C s& |t |�d � }|�tj�}d�|�S )N�/)�len�split�os�sep�join)r
�fullpath�prefix�key_name�lr r r � get_key_name" s
zSubmitter.get_key_namec C sB | j r | j �� }|�||� | jr| jj|d< | j �|� d S d S )N� OutputBucket)r � new_message�for_keyr �name�write)r
�key�metadata�mr r r �
write_message' s
�zSubmitter.write_messageNr r c C sL |si }| � ||�}| j�|�}|�|� |j|d||d� | �||� d S )NF)�replace�cb�num_cb)r r �new_key�update_metadata�set_contents_from_filenamer! )r
�pathr r# r$ r r �kr r r � submit_file/ s
zSubmitter.submit_fileFc C sF t j�|�}t j�|�}t j�|�}d}i } |r || d< g }
t�� D ] } |
�t| �� q"d� |
�| d< | j
rA| j
� | d ddi� t j� |�r�t �
|�D ]6\} }
}|ra|D ] }||
v r`|
�|� qU|D ] }t j� | |�}|rttd| � | �|| |||� |d7 }qcqLnt j�|�r�| �|| ||� |d7 }ntd| � | d |fS ) Nr �Tags�_�Batch�typez
Submitting %s� zproblem with %s)r r( �
expanduser�
expandvars�abspath�time�gmtime�append�strr r �put_attributes�isdir�walk�remove�printr* �isfile)r
r( �tags� ignore_dirsr# r$ �statusr �totalr r �t�root�dirs�files�ignore�filer r r r � submit_path8 sB
�
��
zSubmitter.submit_path)NNr r )NNNr Fr )�__name__�
__module__� __qualname__r
r r! r* rG r r r r r s
r )r3 r �objectr r r r r �<module> s