o ckF[ @s$ddlZddlZGdddeZdS)Nc@s8eZdZddZddZddZdd d Zdd dZdS) SubmittercCsB||_|jd|_|jd|_|jd|_|jd|_dS)N input_bucket output_bucket output_domain input_queue)sdget_objrrrqueue)selfrr 6/usr/lib/python3/dist-packages/boto/services/submit.py__init__s zSubmitter.__init__cCs&|t|d}|tj}d|S)N/)lensplitossepjoin)r fullpathprefixkey_namelr r r get_key_name"s  zSubmitter.get_key_namecCsB|jr|j}||||jr|jj|d<|j|dSdS)N OutputBucket)r new_messagefor_keyrnamewrite)r keymetadatamr r r write_message's   zSubmitter.write_messageNrrcCsL|si}|||}|j|}|||j|d||d|||dS)NF)replacecbnum_cb)rrnew_keyupdate_metadataset_contents_from_filenamer!)r pathrr#r$rrkr r r submit_file/s   zSubmitter.submit_fileFc CsFtj|}tj|}tj|}d}i} |r|| d<g} tD] } | t| q"d | | d<|j rA|j | ddditj |rt |D]6\} } }|ra|D] }|| vr`| |qU|D]}tj | |}|rttd|||| ||||d7}qcqLntj|r||| |||d7}ntd|| d|fS) NrTags_Batchtypez Submitting %szproblem with %s)rr( expanduser expandvarsabspathtimegmtimeappendstrrrput_attributesisdirwalkremoveprintr*isfile)r r(tags ignore_dirsr#r$statusrtotalrrtrootdirsfilesignorefilerr r r submit_path8sB            zSubmitter.submit_path)NNrr)NNNrFr)__name__ __module__ __qualname__r rr!r*rGr r r r rs   r)r3robjectrr r r r s