Submit
Path:
~
/
/
usr
/
lib
/
python2.7
/
site-packages
/
s3transfer
/
File Content:
futures.pyc
� =��Xc @ s� d d l m Z d d l m Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m Z d d l m Z m Z d d l m Z d d l m Z e j e � Z d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ e d d g � Z e d � Z e d � Z d S( i����( t futures( t namedtupleN( t MAXINT( t six( t CancelledErrort TransferNotDoneError( t FunctionContainer( t TaskSemaphoret TransferFuturec B sJ e Z d d d � Z e d � � Z d � Z d � Z d � Z d � Z RS( c C sL | | _ | d k r$ t � | _ n | | _ | d k rH t � | _ n d S( s� The future associated to a submitted transfer request :type meta: TransferMeta :param meta: The metadata associated to the request. This object is visible to the requester. :type coordinator: TransferCoordinator :param coordinator: The coordinator associated to the request. This object is not visible to the requester. N( t _metat Nonet TransferMetat _coordinatort TransferCoordinator( t selft metat coordinator( ( s6 /tmp/pip-build-uEGWVr/s3transfer/s3transfer/futures.pyt __init__ s c C s | j S( s. The metadata associated tio the TransferFuture( R ( R ( ( s6 /tmp/pip-build-uEGWVr/s3transfer/s3transfer/futures.pyR 2 s c C s | j j � S( sm Determines if a TransferFuture has completed :returns: True if completed. False, otherwise. ( R t done( R ( ( s6 /tmp/pip-build-uEGWVr/s3transfer/s3transfer/futures.pyR 7 s c C s; y | j j � SWn# t k r6 } | j � | � n Xd S( s� Waits until TransferFuture is done and returns the result If the TransferFuture succeeded, it will return the result. If the TransferFuture failed, it will raise the exception associated to the failure. N( R t resultt KeyboardInterruptt cancel( R t e( ( s6 /tmp/pip-build-uEGWVr/s3transfer/s3transfer/futures.pyR >