ó
¡ôXc @ s¿ d d l Z d d l m Z m Z d d l m Z d d l m Z d d l m Z d d l
m Z d d l m
Z
d d l m Z d d l m Z d d
l m Z d e e f d „ ƒ YZ d S(
iÿÿÿÿN( t Argt MutuallyExclusiveArgList( t
ArgumentError( t
EC2Request( t DescribeConversionTasks( t
S3AccessMixin( t ImportManifest( t DeleteObject( t GetObject( t AWSErrort DeleteDiskImagec B st e Z d Z e e d d d d ƒe d d d d ƒƒ j ƒ e d d d
d d ƒg Z d „ Z d
„ Z d „ Z RS( s+ Delete a disk image used for an import tasks -ts --taskt helps' ID of the task to delete the image froms -us --manifest-urls location of the import manifests --ignore-active-taskt actiont
store_trues^ delete the image even if the import task is active
(only works with -t/--task)c C sO t j | ƒ | j ƒ | j j d ƒ rK | j j d ƒ rK t d ƒ ‚ n d S( Nt ignore_active_taskt tasks< argument --ignore-active-task my only be used with -t/--task( R t configuret configure_s3_accesst argst getR ( t self( ( sJ /usr/lib/python2.7/site-packages/euca2ools/commands/ec2/deletediskimage.pyR 5 s
%c C s¢ | j j d ƒ r" | j d } n | j j d ƒ rà t j | d | j d g ƒ} | j ƒ d d } | d | j d k s„ t ‚ | j d ƒ r | d } n | d d d } | d
d } n | j d j | ƒ \ } } } d
j | | f ƒ } | j | ƒ } x\ | j D]Q }
t
j | d | j d d | j d d d
j | |
j f ƒ ƒ} | j ƒ qWt
j | d | j d d | j d d | ƒ} | j ƒ d S( Nt manifest_urlR t ConversionTaskIdt conversionTasksi t conversionTaskIdt importVolumet importInstancet volumest imaget importManifestUrlt
s3_servicet /t servicet autht s3_autht path( R R R t
from_othert maint AssertionErrort resolve_url_to_locationt joint# _DeleteDiskImage__download_manifestt image_partsR t key( R R t desc_convR t
vol_containert _t bucketR+ t manifest_s3patht manifestt partt
delete_req( ( sJ /usr/lib/python2.7/site-packages/euca2ools/commands/ec2/deletediskimage.pyR% < s0
( c C s t j d d ƒ ª } t j | d | j d d | j d d | d | d t ƒ} y | j ƒ Wn= t k
r } | j d
k r— t d j
| ƒ ƒ ‚ n ‚ n X| j d ƒ t j
| ƒ SWd QXd S(
Nt max_sizei R R R! R" t sourcet destt
show_progressi” s$ import manifest "{0}" does not existi ( t tempfilet SpooledTemporaryFileR R$ R t FalseR% R t status_codeR t formatt seekR t read_from_fileobj( R t s3patht manifest_destfilet get_reqt err( ( sJ /usr/lib/python2.7/site-packages/euca2ools/commands/ec2/deletediskimage.pyt __download_manifestX s
(
t __name__t
__module__t DESCRIPTIONR R t requiredt ARGSR R% R) ( ( ( sJ /usr/lib/python2.7/site-packages/euca2ools/commands/ec2/deletediskimage.pyR
) s ( R8 t requestbuilderR R t requestbuilder.exceptionsR t euca2ools.commands.ec2R t. euca2ools.commands.ec2.describeconversiontasksR t euca2ools.commands.ec2.mixinsR t! euca2ools.commands.ec2.structuresR t" euca2ools.commands.s3.deleteobjectR t euca2ools.commands.s3.getobjectR t euca2ools.exceptionsR R
( ( ( sJ /usr/lib/python2.7/site-packages/euca2ools/commands/ec2/deletediskimage.pyt <module> s