/usr/lib/rads/venv/lib/python3.13/site-packages/s3transfer/__pycache__
Edit: /usr/lib/rads/venv/lib/python3.13/site-packages/s3transfer/__pycache__/crt.cpython-313.pyc (42868B)
j S SK r S SKrS SKrS SKJr S SKrS SKrS SKr S SK
r S SK J r J
r
JrJr S SKJrJrJrJrJr S SKJrJrJr S SK Jr S SKJr S SK J r S S K J r S S
K J!r!J"r" S S K#J$r$J%r% S S K&J'r' S S
K(J)r)J*r* S SK+J,r, S SK-J.r.J/r/J0r0J1r1J2r2 \ Rf " \45 r5Sq6S r7SSSS\%- SS4S jr8S/S jr9 " S S5 r: " S S\*5 r; " S S\)5 r< " S S 5 r= " S S \=5 r> " S S \5 r? " S! S"5 r@ " S# S$5 rA " S% S&5 rB " S' S(5 rC " S) S*5 rD " S+ S,5 rE " S- S.5 rFg)0 N)BytesIO)AwsCredentialsAwsCredentialsProviderAwsSigningAlgorithmAwsSigningConfig)ClientBootstrapClientTlsContextDefaultHostResolverEventLoopGroupTlsContextOptions)S3ClientS3RequestTlsMode
S3RequestType)UNSIGNED)urlsplit)Config)NoCredentialsError) ArnParserInvalidArnException)FULL_OBJECT_CHECKSUM_ARGSMB)TransferNotDoneError)BaseTransferFutureBaseTransferMeta)TransferManager)CallArgsOSUtilscreate_nested_client
get_callbacksis_s3express_bucketc [ c2 [ R R U 5 n UR 5 Uq [ $ ! [
a g f = fN)CRT_S3_PROCESS_LOCKawscrts3CrossProcessLockacquire RuntimeError)namecrt_locks A/usr/lib/rads/venv/lib/python3.13/site-packages/s3transfer/crt.pyacquire_crt_s3_process_lockr, ; sS "99--d3 '
s A
A
A
Tc T [ U5 n[ U5 n[ Xx5 n Sn
U( a [ R O[ R
n UbC [
5 n U( a U R US9 OSU l [ U 5 n
U
R 5 n
[ US9n[ U U UUU U
USS9$ )a
:type region: str
:param region: The region used for signing
:type crt_credentials_provider:
Optional[awscrt.auth.AwsCredentialsProvider]
:param crt_credentials_provider: CRT AWS credentials provider
to use to sign requests. If not set, requests will not be signed.
:type num_threads: Optional[int]
:param num_threads: Number of worker threads generated. Default
is the number of processors in the machine.
:type target_throughput: Optional[int]
:param target_throughput: Throughput target in bytes per second.
By default, CRT will automatically attempt to choose a target
throughput that matches the system's maximum network throughput.
Currently, if CRT is unable to determine the maximum network
throughput, a fallback target throughput of ``1_250_000_000`` bytes
per second (which translates to 10 gigabits per second, or 1.16
gibibytes per second) is used. To set a specific target
throughput, set a value for this parameter.
:type part_size: Optional[int]
:param part_size: Size, in Bytes, of parts that files will be downloaded
or uploaded in.
:type use_ssl: boolean
:param use_ssl: Whether or not to use SSL. By default, SSL is used.
Note that not all services support non-ssl connections.
:type verify: Optional[boolean/string]
:param verify: Whether or not to verify SSL certificates.
By default SSL certificates are verified. You can provide the
following values:
* False - do not validate SSL certificates. SSL will still be
used (unless use_ssl is False), but SSL certificates
will not be verified.
* path/to/cert/bundle.pem - A filename of the CA cert bundle to
use. Specify this argument if you want to use a custom CA cert
bundle instead of the default one on your system.
N) ca_filepathF) provided_throughput_target_bytesT) bootstrapregioncredential_provider part_sizetls_modetls_connection_optionsthroughput_target_gbpsenable_s3express)
r r
r r ENABLEDDISABLEDr &override_default_trust_store_from_path verify_peerr new_connection_options _get_crt_throughput_target_gbpsr
)r2 crt_credentials_provider num_threadstarget_throughputr4 use_sslverifyevent_loop_group
host_resolverr1 r6 r5 tls_ctx_optionsclient_tls_option target_gbpss r+ create_s3_crt_clientrI T s h &k2'(89M 0@I ! %, 1A1J1J
+- B B "
C
+0O ' ,_ =!2!I!I!K 1):K 4 5 * c U c: [ R R 5 n[ R SU5 Uc SnOU S- S- n[ R SU5 U$ )Nz-Recommended CRT throughput target in gbps: %sg $@r- i ʚ;z'Using CRT throughput target in gbps: %s)r$ r% &get_recommended_throughput_target_gbpsloggerdebug)r0 rH s r+ r> r> s_ '/ iiFFH ;[
K 7:]J
LL:KH rJ c \ rS rSr\R
r\R r\R rSr\R r SS jr
S r S r SS jr
SS jrSS jrSS
jrS rS rS
rS rS rS rSS jrS rS rSrg)CRTTransferManager TNc Uc [ 5 U l Xl [ X R 5 U l UR
U l / U l [ R " S5 U l
SU l g)a A transfer manager interface for Amazon S3 on CRT s3 client.
:type crt_s3_client: awscrt.s3.S3Client
:param crt_s3_client: The CRT s3 client, handling all the
HTTP requests and functions under then hood
:type crt_request_serializer: s3transfer.crt.BaseCRTRequestSerializer
:param crt_request_serializer: Serializer, generates unsigned crt HTTP
request.
:type osutil: s3transfer.utils.OSUtils
:param osutil: OSUtils object to use for os-related behavior when
using with transfer manager.
N r ) r _osutil_crt_s3_clientS3ClientArgsCreator_s3_args_creatortranslate_crt_exception_crt_exception_translator_future_coordinators threading Semaphore
_semaphore _id_counter)self
crt_s3_clientcrt_request_serializerosutils r+ __init__CRTTransferManager.__init__ sc >"9DL + 3 "LL!
# : :
& %'!#--c2 rJ c U $ r" r_ s r+ __enter__ CRTTransferManager.__enter__ s rJ c < SnU( a SnU R U5 g )NFT _shutdown)r_ exc_type exc_valueargscancels r+ __exit__CRTTransferManager.__exit__ s F v rJ c Uc 0 nUc 0 nU R X@R 5 U R U5 [ UUUUUS9nU R SU5 $ )Nbucketkeyfileobj
extra_args subscribers
get_object)_validate_all_known_argsALLOWED_DOWNLOAD_ARGS _validate_if_bucket_supportedr _submit_transfer)r_ ru rv rw rx ry callargss r+ downloadCRTTransferManager.download sj J K %%j2L2LM **62!#
$$\8<
>I
K 00FF # L " 0 0 = = M MN
& &~ 6 !!((5 A
% %a .++<<2E = G
! s -A8D( (
E/23E**E/)rY rU rZ r^ rT rW r] r" NNF)__name__
__module__ __qualname____firstlineno__r r| r r r r rc rh rq r r r r r} r{ r r r r rl r r~ __static_attributes__rf rJ r+ rP rP s + A A)==)=='+$#2#O#O : BF=$="
@ %
!@ ("'rJ rP c R \ rS rSrSrS S jr\S 5 r\S 5 r\S 5 r Sr
g)
r i z*Holds metadata about the CRTTransferFutureNc * Xl X l 0 U l g r" ) _transfer_id
_call_args
_user_context)r_ r r s r+ rc CRTTransferMeta.__init__ s '# rJ c U R $ r" )r rg s r+ r CRTTransferMeta.call_args s rJ c U R $ r" )r rg s r+ r CRTTransferMeta.transfer_id s rJ c U R $ r" )r rg s r+ user_context CRTTransferMeta.user_context s !!!rJ )r r r r ) r r r r __doc__rc propertyr r r r rf rJ r+ r r sF 4
! ! " "rJ r c J \ rS rSrS
S jr\S 5 rS rS S jrS r S r
S r g) r i Nc @ Xl Uc [ 5 U l X l g)a2 The future associated to a submitted transfer request via CRT S3 client
:type meta: s3transfer.crt.CRTTransferMeta
:param meta: The metadata associated to the transfer future.
:type coordinator: s3transfer.crt.CRTTransferCoordinator
:param coordinator: The coordinator associated to the transfer future.
N)_metar _coordinator)r_ r r s r+ rc CRTTransferFuture.__init__ s
<(*DJ 'rJ c U R $ r" )r rg s r+ r CRTTransferFuture.meta s zzrJ c 6 U R R 5 $ r" )r r rg s r+ r CRTTransferFuture.done s %%''rJ c : U R R U5 g r" )r r r_ timeouts r+ r CRTTransferFuture.result s )rJ c 8 U R R 5 g r" )r rp rg s r+ rp CRTTransferFuture.cancel s "rJ c x U R 5 ( d [ S5 eU R R USS9 g)z!Sets the exception on the future.z?set_exception can only be called once the transfer is complete.T)overrideN)r r r r r_ exceptions r+ r CRTTransferFuture.set_exception s: yy{{&
'' D'ArJ )r r r r" ) r r r r rc r r r r rp r r rf rJ r+ r r s0 ( (*#BrJ r c \ rS rSrS rS rSrg)BaseCRTRequestSerializeri c [ S5 e)a4 Serialize CRT HTTP requests.
:type transfer_type: string
:param transfer_type: the type of transfer made,
e.g 'put_object', 'get_object', 'delete_object'
:type future: s3transfer.crt.CRTTransferFuture
:rtype: awscrt.http.HttpRequest
:returns: An unsigned HTTP request to be used for the CRT S3 client
zserialize_http_request()NotImplementedError)r_
transfer_typer s r+ serialize_http_request/BaseCRTRequestSerializer.serialize_http_request s ""<==rJ c [ S5 e)Nztranslate_crt_exception()r
r s r+ rX 0BaseCRTRequestSerializer.translate_crt_exception s !"=>>rJ rf N)r r r r r rX r rf rJ r+ r r s > ?rJ r c ` \ rS rSrSS jrS rS rS rS rS r S r
S
r S r S r
S
rS rSrg) BotocoreCRTRequestSerializeri Nc . Xl Uc 0 nU R X5 [ U40 UD6U l U R R R
R
SU R 5 U R R R
R
SU R 5 U R R R
R
SU R 5 U R R R
R
SU R 5 g)a Serialize CRT HTTP request using botocore logic
It also takes into account configuration from both the session
and any keyword arguments that could be passed to
`Session.create_client()` when serializing the request.
:type session: botocore.session.Session
:type client_kwargs: Optional[Dict[str, str]])
:param client_kwargs: The kwargs for the botocore
s3 client initialization.
Nzrequest-created.s3.*zafter-call.s3.*zbefore-send.s3.*zbefore-call.s3.*) _session_resolve_client_configr _clientr eventsregister_capture_http_request+_change_response_to_serialized_http_request_make_fake_http_response_remove_checksum_context)r_ session
client_kwargss r+ rc %BotocoreCRTRequestSerializer.__init__ s
M ##G;+GE}E )) "D$>$>
)) t O O
)) = =
)) = =
rJ c S nUR 5 ( a UR 5 nSU; a US n[ [ S9nU( a UR U5 nXBS' SUS' g )Nconfig)signature_versionr% service_name)get_default_client_configr r merge)r_ r r! user_provided_config
client_configs r+ r 3BotocoreCRTRequestSerializer._resolve_client_config sh # , , . .#*#D#D#F } $#0#: :
0 6 6} EM"/h (,
n%rJ c [ UR 5 nUR nUR ( a U SUR 3n/ nUR R 5 HK u pV[
U[ 5 ( a UR XV45 M. UR U[ US5 45 MM [ R R U5 n[ R R UR UUUR S9nU$ )N?zutf-8)methodpathheaders body_stream)r urlr/ queryr0 r
isinstancestrr r$ http HttpHeaders HttpRequestr. body) r_ aws_request url_partscrt_path headers_listr) value crt_headers crt_requests r+ _crt_request_from_aws_request:BotocoreCRTRequestSerializer._crt_request_from_aws_request s [__- >> ??"1Y__$56H &..446KD%%% ##TM2 ##T3ug+>$?@ 7 kk--l; kk-- %% #(( .
rJ c < U R U5 nUR R S5 c; [ UR 5 nUR R SUR 5 UR R S5 b UR R S5 UR R S5 c) UR c UR R SS5 UR R S5 b UR R S5 U$ )Nhostz Content-MD5zContent-Length0zTransfer-Encoding)
rA r0 r r r2 setnetlocremover9 add)r_ botocore_http_requestr@ r; s r+ _convert_to_crt_http_request9BotocoreCRTRequestSerializer._convert_to_crt_http_request s 889NO " "6 * 2 !6!:!:;I # #FI,<,< = " "= 1 = & &} 5 " "#3 4 <$))1##''(8#> " "#6 7 C & &': ;rJ c XR S' g )N http_request)contextr_ requestr s r+ r 2BotocoreCRTRequestSerializer._capture_http_request4 s *1'rJ c 4 US nUR 5 US' g )NrN HTTPRequest)prepare)r_ rO parsedr rQ s r+ r HBotocoreCRTRequestSerializer._change_response_to_serialized_http_request7 s .) ' 1} rJ c X [ R R S S0 [ S5 5 $ )N rJ )botocore
awsrequest AWSResponseFakeRawResponserP s r+ r 5BotocoreCRTRequestSerializer._make_fake_http_response= s, "".. C
rJ c [ U R U5 " SUR UR S.UR D6S $ )N)BucketKeyrT rf )getattrr ru rv rx )r_
client_methodr s r+ _get_botocore_http_request7BotocoreCRTRequestSerializer._get_botocore_http_requestE sD t||]3
##
:C:N:N
rJ c r U R XR R 5 nU R U5 nU$ r" )rd r r rK )r_ r r rJ r@ s r+ r 3BotocoreCRTRequestSerializer.serialize_http_requestJ s9 $ ? ? ;;00!
778MN rJ c x [ U[ R R 5 ( a U R U5 $ g r" )r4 r$ r% S3ResponseError _translate_crt_s3_response_errorr s r+ rX 4BotocoreCRTRequestSerializer.translate_crt_exceptionQ s- i!:!: ; ;88C CrJ c F UR nUS: a g UR VVs0 s H u p4X4_M nnnUR nUb< U R R R
nUR
U5 R nOS n[ R R U5 UUR S.n U R R R XS9n
U
R S0 5 R S5 n U R R R! U 5 n U " XS9$ s snnf )Ni- )r0 status_coder9 )shapeErrorCode)operation_name)rm r0 rq r r
service_modeloperation_model output_shaperZ r[ HeadersDictr9 _response_parserparser
exceptions from_code)
r_ s3_response_errorrm kvr0 rq rr rn
response_dictparsed_response
error_code error_classs
r+ rj =BotocoreCRTRequestSerializer._translate_crt_s3_response_errorW s '33 $5$=$=>$=DA14$=>*99 % LL - - ; ;M!11.ANNEE **66w?&%**
,,77== >
%(("599&A
ll--77
C ?JJ' ?s D c < UR S0 5 nSU; a US g g )NrO checksum)r )r_ paramsr request_contexts r+ r 5BotocoreCRTRequestSerializer._remove_checksum_contexts s' **Y3 (
+ )rJ )r r r" )r r r r rc r rA rK r r r rd r rX rj r r rf rJ r+ r r s?
< -, <22
K8,rJ r c \ rS rSrSS jrSrg)r] iy Nc # J # U R U5 nU( d g Uv M 7fr" )read)r_ amtdecode_contentchunks r+ streamFakeRawResponse.streamz s% IIcNEK s !#rf )i N)r r r r r r rf rJ r+ r] r] y s rJ r] c , \ rS rSrS rS rS rS rSrg) BotocoreCRTCredentialsWrapperi c Xl g r" _resolved_credentials)r_ resolved_botocore_credentialss r+ rc &BotocoreCRTCredentialsWrapper.__init__ s %B"rJ c U R 5 R 5 n[ UR UR UR
5 $ r" )_get_credentialsget_frozen_credentialsr
access_key
secret_keytoken)r_ credentialss r+ __call__&BotocoreCRTCredentialsWrapper.__call__ s? ++-DDF " "K$:$:K / nTb UT-
nU[ TT5 -
nTb UT-
nU H nTS:X a U" U S S9 M U" U 0 UD6 M g )Nprogressr )bytes_transferred)r )ro r callbacks_listcallbackr before_subscribers
callback_typer s r+ invoke_all_callbacksBS3ClientArgsCreator.get_crt_callback..invoke_all_callbacks sh N!- "44 mFM B BN , "33 * !J. tAw7 d-f- +rJ rf )r_ r r r r r s ```` r+ r $S3ClientArgsCreator.get_crt_callback s . . $#rJ c ^ S n[ TR [ 5 ( a7 TR nU R R U5 nUTR
S' OTR TR
S' S n [
U4S j[ 5 5 ( d TR
R SS5 R 5 n
[ R R [ R R U
[ R R R S9n STR
S' U R! UTUUUUS 9n X{S
' XS ' U $ ) N
ContentLengthBodyc 3 B ># U H nUTR ; v M g 7fr" )rx ).0 checksum_argr s r+ HS3ClientArgsCreator._get_make_request_args_put_object.. s#
9
I 0 0 0 9s r CRC32) algorithmlocationzoverride-to-be-removed
ContentMD5r
send_filepathchecksum_config)r4 rw r5 r
get_file_sizerx anyr popr r$ r% S3ChecksumConfigr S3ChecksumLocationTRAILERr ) r_ r r r r r r r data_lenr r make_request_argss ` r+ !_get_make_request_args_put_object5S3ClientArgsCreator._get_make_request_args_put_object
s>
i'' - - % - -M~~33MBH4+, rJ c S nS n[ R R SS9n [ UR [
5 ( aM UR n
U R R U
5 nUR [ X:XpR 5 5 O[ UR 5 nU R UUUUUUS9n X{S' XS' XS' U $ )NT)validate_responser
recv_filepathon_bodyr ) r$ r% r r4 rw r5 r get_temp_filenamer RenameTempFileHandlerOnBodyFileObjWriterr ) r_ r r r r r r r r r final_filepathr s r+ !_get_make_request_args_get_object5S3ClientArgsCreator._get_make_request_args_get_object< s
))44t4L i'' - - & . .N NN < <^ LM ' '%
*)*;*;+, rJ c U R R X5 [ [ UR 5 [ R
5 U R
USXV5 U R
US5 S.nUS [ R
:X a* SR S UR S5 5 5 US' [ 5 nUR UR 5 =n ( a2 U S S:X a) [ [ R S
S S S 9US
' U S Ul U$ [ UR 5 ( a [ [ R S S S9US
' U$ )Nr r )rQ typer on_progressr c 3 @ # U H oR 5 v M g 7fr" )title)r xs r+ r ES3ClientArgsCreator._default_get_make_request_args..y s :#:a #:s _rq r2 *F)r r2 use_double_uri_encodeshould_normalize_uri_pathsigning_config
resource_name)r r r )r r rb r r DEFAULTr r split_S3ArnParamHandler
handle_arnru r r
V4_ASYMMETRICr V4_S3EXPRESS)
r_ r r r r r r r arn_handleraccesspoint_arn_detailss
r+ r 2S3ClientArgsCreator._default_get_make_request_args` s^ //FF | 1 1 3]5J5J ,, 4 00D
V $
(=(= =24'' :#/#5#5c#:: 3 . / )* '2'='=i>N>N'O O # O%h/25
3C-;;&+*/ 3 . / 7 GI ! !!1!1
2
2 3C-::&+*/3 . /
! rJ )r r r ) r r r r rc r r r r r r rf rJ r+ rV rV s* "
* $2-!^"!H4!rJ rV c \ rS rSrS rS rSrg)r i c 4 Xl X l X0l X@l g r" )r _final_filename_temp_filenamerT )r_ r final_filename
temp_filenamerb s r+ rc RenameTempFileHandler.__init__ s ' - + rJ c x US nU( a& U R R U R 5 g U R R U R U R 5 g ! [
aJ nU R R U R 5 U R R U5 S nAg S nAff = f)Nr )rT remove_filer rename_filer r r r )r_ r r r s r+ r RenameTempFileHandler.__call__ s w LL $ $T%8%8 9
3 (('')=)=
3 (()<)<=!!//22
3s 0A% %
B9/A B44B9)r r rT r Nr r r r rc r r rf rJ r+ r r s 3rJ r c \ rS rSrS rS rSrg)r i c Xl g r" r r s r+ rc AfterDoneHandler.__init__ s 'rJ c 8 U R R 5 g r" )r r r s r+ r AfterDoneHandler.__call__ s 557rJ r) Nr& rf rJ r+ r r s (8rJ r c \ rS rSrS rS rSrg)r i c Xl g r" _fileobj)r_ rw s r+ rc OnBodyFileObjWriter.__init__ s
rJ c : U R R U5 g r" )r0 write)r_ r r s r+ r OnBodyFileObjWriter.__call__ s
E"rJ r/ Nr& rf rJ r+ r r s #rJ r c T \ rS rSrSr\R " S5 rS rS r S r
S r Sr g )
r i zPartial port of S3ArnParamHandler from botocore.
This is used to make a determination on MRAP accesspoints for signing
purposes. This should be safe to remove once we properly integrate auth
resolution from Botocore into the CRT transfer integration.
zA^(?Paccesspoint|outpost)[/:](?P.+)$c " [ 5 U l g r" )r _arn_parserrg s r+ rc _S3ArnParamHandler.__init__ s $;rJ c D U R U5 nUc g US S:X a U$ g )N
resource_type accesspoint) _get_arn_details_from_bucketr_ ru arn_detailss r+ r _S3ArnParamHandler.handle_arn s3 77? '= 8 9rJ c U R R U5 nU R U5 U$ ! [ a g f = fr" )r7 parse_arn_add_resource_type_and_namer r= s r+ r< /_S3ArnParamHandler._get_arn_details_from_bucket sF **44V r s r+ rB ._S3ArnParamHandler._add_resource_type_and_name sK $$**;z+BC +0;;+GK (+0;;+GK ( rJ )r7 N)
r r r r r recompilerE rc r r< rB r rf rJ r+ r r s/ jjLO' HrJ r r" )GloggingrH r[ ior awscrt.httpr$ awscrt.s3botocore.awsrequestrZ botocore.session awscrt.authr r r r awscrt.ior r r
r r r
r r r botocore.compatr botocore.configr botocore.exceptionsr botocore.utilsr r s3transfer.constantsr r s3transfer.exceptionsr s3transfer.futuresr r s3transfer.managerr s3transfer.utilsr r r r r getLoggerr rM r# r, rI r> rP r r r r r] r r rV r r r r rf rJ r+ r\ s@ @ ? $ " 2 9 > 6 C .
8 $ 6 ""f Rj$H HV"& "*#B* #BL? ?&b,#; b,Jg * *&F< F