o ckF[ã ã@s$ddlZddlZGdd„deƒZdS)éNc@s8eZdZdd„Zdd„Zdd„Zdd d „Zdd d„ZdS)Ú SubmittercCsB||_|j d¡|_|j d¡|_|j d¡|_|j d¡|_dS)NÚ input_bucketÚ output_bucketÚ output_domainÚ input_queue)ÚsdÚget_objrrrÚqueue)Úselfr©r ú6/usr/lib/python3/dist-packages/boto/services/submit.pyÚ__init__s zSubmitter.__init__cCs&|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_namecCsB|jr|j ¡}| ||¡|jr|jj|d<|j |¡dSdS)NÚ OutputBucket)r Ú new_messageÚfor_keyrÚnameÚwrite)r ÚkeyÚmetadataÚmr r r Ú write_message's   ûzSubmitter.write_messageNrrcCsL|si}| ||¡}|j |¡}| |¡|j|d||d| ||¡dS)NF)ÚreplaceÚcbÚnum_cb)rrÚnew_keyÚupdate_metadataÚset_contents_from_filenamer!)r Úpathrr#r$rrÚkr r r Ú submit_file/s   zSubmitter.submit_fileFc CsFtj |¡}tj |¡}tj |¡}d}i} |r|| d<g} t ¡D] } |  t| ƒ¡q"d  | ¡| d<|j rA|j   | dddi¡tj  |¡r„t  |¡D]6\} } }|ra|D] }|| vr`|  |¡qU|D]}tj  | |¡}|rttd|ƒ| || |||¡|d7}qcqLntj |¡r—| || ||¡|d7}ntd|ƒ| d|fS) NrÚTagsÚ_ÚBatchÚtypez Submitting %sézproblem with %s)rr(Ú expanduserÚ expandvarsÚabspathÚtimeÚgmtimeÚappendÚstrrrÚput_attributesÚisdirÚwalkÚremoveÚprintr*Úisfile)r r(ÚtagsÚ ignore_dirsr#r$ÚstatusrÚtotalrrÚtÚrootÚdirsÚfilesÚignoreÚfilerr r r Ú submit_path8sB      €  ûû    zSubmitter.submit_path)NNrr)NNNrFr)Ú__name__Ú __module__Ú __qualname__r rr!r*rGr r r r rs   r)r3rÚobjectrr r r r Ús