+ i ^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIH t H t H t ^RI H t ^RIHt^RIHt^RIHt^RIHt^RIHtHtHtHtHtHtHtHtHt^R I H!t!H"t"H#t#H$t$^RI%t%^R I%H&t&^R I'H(t(H)t)H*t*]PV!],4t-R t.]]R .]/3,,t0Rt1Rt2RRlt3RNRRllt4RRlt5RRlt6!RR4t7!RR]74t8!RR]74t9!RR4t:!R R ];4tR$R/R%R&llt?R'RR(RR)^R*^R+RR,RR-RR.RR/R0R1R0R$RR2RR3R4R5R0R6R7R8R4/R9R:llt@ROR;R<lltARPR>R?lltB!R@RA]4tCRB]D!RC4R(RRD]-PR,RR-RRERR$RRFRR6R7RGR0RHR=/ RIRJlltF!RKRL4tGRORMltHR#)QN)ThreadPoolExecutor TimeoutError as_completed) parsedate)partial) NOT_FOUND)count)create_default_context) AnyCallableIteratorListMapping NamedTupleOptionalTupleUnion)quoteurlparseurlsplit urlunparse) exceptions) performanceutilversionREDACTEDUrlErrorc\\VRR74pV^,'g!V^,'dV^,V^&RV^&\V4#)http)scheme)listrr)url parsed_urls& 6/usr/lib/python3/dist-packages/cloudinit/url_helper.py _cleanurlr&1sGhs623J a==Z]]#1 1  1 j !!c2RpTpVF pV!W44pK V#)c\\V44pV^,pV'd!VPR4'g VR, pV\\ V4RR7, pW2^&\ V4#)/z/:)safe)r"rendswithrstrr)r#add_on url_parsedpaths&& r%combine_single#combine_url..combine_single<sZ(3-( !}  c** CKD c&k--1 *%%r')baseadd_onsr2r#r/s&* r% combine_urlr7;s'& CS) Jr'c$V^8dQhR\/#r*returnint)formats"r% __annotate__r>Kssr'c t\PR\PR\PR\PR\ R/pVP \V44pV'gN\V\4'd!VP'dVPpV#\PR4RpV#)z4helper for read_ftps to map return codes to a number,iXiz9Unexpected exception type while connecting to ftp server.i) ftplib error_reply error_temp error_perm error_protoEOFErrorgettype isinstanceOSErrorerrnoLOGwarning)excftp_error_codescodes& r%"ftp_get_return_code_from_exceptionrSKs C33C# O   tCy )D  c7 # # 99D K KKK D Kr'c@V^8dQhR\R\R\RR/#)r*r#timeoutkwargsr: FtpResponse)r.floatdict)r=s"r%r>r>bs.3r'c \V4pVP'g\R\RVR7h\P !4;_uu_4pVP ;'g^pVP;'gRpRVP8XEdW\P!\4R7p\PRVV4TPVPTT;'gRR 7\PR T4TP#TTP$;'gRR7\PR4TP'4\PRTP,4TP/RTP, 2TP0R7\3TP54T4\PR4TP74uuRRR4#\P8!4p \PRW4T PVPTT;'gRR 7\PR V4T P#TVP$;'gRR7\PRVP,4V P/RVP, 2VP0R7\3VP54V4\PR4V P74uuRRR4# \Pd(p\!T4p \R T R T R 2T RTR7ThRp?ii;i \P(d+p\P+R4\RRRTR7ThRp?ii;i \Pd(p\!T4p \RT R T R 2T RTR7ThRp?ii;i \PR4TP74i;i \Pd(p\!T4p \RT R T R 2T RTR7ThRp?ii;i \PR4X P74i;i +'giR#;i)aOconnect to URL using ftp over TLS and read a file when using strict mode (ftps://), raise exception in event of failure when not using strict mode (ftp://), fall back to using unencrypted ftp url: string containing the destination to read a file from. The url is parsed with urllib.urlsplit to identify username, password, host, path, and port in the following format: ftps://[username:password@]host[:port]/[path] host is the only required component timeout: maximum time for the connection to take kwargs: unused, for compatibility with read_url returns: UrlResponse zInvalid url providedNcauserRheadersr# anonymousftps)contextz3Attempting to connect to %s via port [%s] over tls.@)hostportrUz1Reading file from server over tls failed for url z []z"Attempting to login with user [%s]r!)userpasswdzCreating a secure connectionzAttempted to connect to an insecure ftp server but used a scheme of ftps://, which is not allowed. Use ftp:// to allow connecting to insecure ftp servers.rBzReading file: %szRETR )callbackzClosing connectionz,Reading file from ftp server failed for url z(Attempting to connect to %s via port %s.)rhostnamerrioBytesIOrcusernamer rCFTP_TLSr rNdebugconnect all_errorsrSloginpasswordprot_prFrOr1 retrbinarywriterWgetvaluecloseFTP) r#rUrV url_partsbufferrcreftp_tlserRftps &&, r% read_ftpsr}bs  I    (y$C   ~~##!!00[ Y%% %  ..24 I "++#NNs  II:D A  $--33 89 "  ,inn=""INN+,v||##6??#4c: ./ S V jjl > "++#NNs  >E $--33 ,inn=y~~&67&,,O"6??#4c: ./ U $$$ 9!<**-ba9  &$$  C N     .$$ 9!<++.%r$q:   ./ ($$ 9!<++.%r$q:   ./ U s)Q8QAL$L,QM"-MA#N3%Q$BO1,A+O1%QM"L>>MQN%NNQO"N??OO'O..Q1P-"P((P--P00'QQ Q+ c(V^8dQhR\RR/#)r*r1r: FileResponser.)r=s"r%r>r>s M MS M~ Mr'c <VPR4'd\PRV4\P!V4p\ W 4# \ dp\T\RTR7ThRp?i\dp\Y3PRTR7ThRp?ii;i)zeread a binary file and return a FileResponse matches function signature with read_ftps and read_url dataz'Unable to post data to file resource %sNr[) rIrNrOrload_binary_filerFileNotFoundErrorrrIOErrorrM)r1rVcontentsr{s&, r% _read_filers zz& =tDM((.H++ OQY$GQN MQWWdE1LMs) A BA// B<B=BBc2V^8dQhR\R,/#)r*r:)r UrlResponserW)r)r=s"r%r>r>s&& 78&r'c VP4p\V4pTPpTR8XgT'd%RT^,8Xd\ TP 3/TB#TR9d \T3/TB#TR9d \T3/TB#\PRT4\T3/TB# \dp\Y0R7ThRp?ii;i)a Wrapper function around readurl to allow passing a file path as url. When url is not a local file path, passthrough any kwargs to readurl. In the case of parameter passthrough to readurl, default values for some parameters. See: call-signature of readurl in this module for param docs. )r\r#Nfiler+zAttempting unknown protocol %s)r|r_)rhttps) lstripr ValueErrorrr rr1r}readurlrNrO)r#rVparsedr{r s&, r%read_file_or_urlrs **,C0#]]F CC3q6M&++000 ? "''' $ $s%f%% 4f=s%f%% 0Q(a/0s B$$ C/ B<<Cc6a]tRtRtoRRltRtRtRtVtR#)StringResponseic8W0n/VnWnW nR#N)rRr]rr#)selfrr#rRs&&&&r%__init__StringResponse.__init__s   r'c VP^8H#rRrargsrVs&*,r%okStringResponse.oksyyCr'c8VPPR4#)zutf-8)rdecoders&r%__str__StringResponse.__str__s}}##G,,r')rRrr]r#Nr) __name__ __module__ __qualname____firstlineno__rrr__static_attributes____classdictcell__ __classdict__s@r%rrs  --r'rcBaa]tRtRtoRV3RlV3RllltRtVtV;t#)ri c&<V^8dQhRS[RS[/#r*rr#bytesr.)r=rs"r%r>FileResponse.__annotate__!s333S3r'c*<\SV`WVR7R#)rNsuperr)rrr#rR __class__s&&&&r%rFileResponse.__init__!s T2r'r4rrrrrrrr __classcell__rrs@@r%rr s333r'rc>aa]tRtRtoV3RlV3RlltRtVtV;t#)rWi%c&<V^8dQhRS[RS[/#rr)r=rs"r%r>FtpResponse.__annotate__&s(((S(r'c&<\SV`W4R#rr)rrr#rs&&&r%rFtpResponse.__init__&s 'r'r4rrs@@r%rWrW%s(((r'rWca]tRtRtoV3RlRlt]V3RlRl4t]V3RlRl4tRV3RlR llt]R 4t ]V3R lR l4t R t RV3RlRllt Rt VtR#)ri*c4<V^8dQhRS[P/#)r*response)requestsResponse)r=rs"r%r>UrlResponse.__annotate__+s""!2!2"r'cWnR#r _response)rrs&&r%rUrlResponse.__init__+s!r'c <V^8dQhRS[/#r9)r)r=rs"r%r>r/s&&%&r'cbVPPfR#VPP#)Nr')rcontentrs&r%rUrlResponse.contents.s% >> ! ! )~~%%%r'c <V^8dQhRS[/#r9r)r=rs"r%r>r5s""S"r'c.VPP#r)rr#rs&r%r#UrlResponse.url4s~~!!!r'c <V^8dQhRS[/#r9)bool)r=rs"r%r>r8sr'c\RpV'dRp^VPu;8:d V8dR#R#R#)r@rATFr)r redirects_okuppers&& r%rUrlResponse.ok8s- E $)) #e # $r'c.VPP#r)rr]rs&r%r]UrlResponse.headersAs~~%%%r'c <V^8dQhRS[/#r9r;)r=rs"r%r>rFs**c*r'c.VPP#r)r status_coders&r%rRUrlResponse.codeEs~~)))r'c.VPP#r)rtextrs&r%rUrlResponse.__str__Is~~"""r'cL<V^8dQhRS[S[,RS[RS[S[,/#)r* chunk_sizedecode_unicoder:)rr<rr r)r=rs"r%r>rLs2 K K"3- K=A K % Kr'c# X"VPPW4RjxL R#L5i)aDIterates over the response data. When stream=True is set on the request, this avoids reading the content at once into memory for large responses. :param chunk_size: Number of bytes it should read into memory. :param decode_unicode: If True, content will be decoded using the best available encoding based on the response. N)r iter_content)rrrs&&&r%rUrlResponse.iter_contentLs>>..zJJJs *(*rN)F)F)rrrrrpropertyrr#rr]rRrrrrrs@r%rr*s""&& ""&&**# K K Kr'rc6a]tRtRtoRV3RlRlltRtVtR#)ri[Nc b<V^8dQhRS[RS[S[,RS[S[,RS[S[,/#)r*r\rRr]r#)r rr<rr.)r=rs"r%r>UrlError.__annotate__\s@   sm '"  c] r'c\PV\V44WnW nVf/MTVnW@nR#r)rrr.r\rRr]r#)rr\rRr]r#s&&&&&r%rUrlError.__init__\s4 s5z*  &-o7 r'r[)NNN)rrrrrrrrs@r%rr[s   r'c$/p\V4PpVR8XdrV'djRV9dVR,'dVR,VR&MRVR&RV9dRV9dVR,VR,.VR&V#RV9d\VR,4VR&V#)rca_certsverifyT cert_filekey_filecert)rr r.)r# ssl_detailsssl_argsr s&& r% _get_ssl_argsrjsH c] ! !F [  $Z)@)@!,Z!8HX !%HX  + %* *CK(J' HV  OK '";{#;r>|s!!#!%!r'c\V4pV# \dp\T4pT'g \R4Th\\P!T4\P!4, 4pM) \d\ P RT4^pMi;iT^8d\ P R4^pRp?T#Rp?ii;i)a(Parse a Retry-After header value into an integer. : param retry_after: The value of the Retry-After header. https://www.rfc-editor.org/rfc/rfc9110.html#section-10.2.3 https://www.rfc-editor.org/rfc/rfc2616#section-3.3 : return: The number of seconds to wait before retrying the request. z(Failed to parse Retry-After header valuezGFailed to parse Retry-After header value: %s. Waiting 1 second instead.zBRetry-After header value is in the past. Waiting 1 second instead.N)rXrrtimemktimerNinfo)rto_waitrP time_tuples& r%_get_retry_afterr|s $0 N/  ";/J >DKK 3diikABG  HH,  G   Q; HH, G N/s3  CAA43C4#BCB!CC exception_cbcRV^8dQhR\R\R\\,/#)r*errorrr:)rExceptionCallbackrrX)r=s"r%r>r>s,    $ e_ r'clV'dV!V4'dR#VP'dVPR8Xdo\PRVP4VP'd&\ VPP RR44#\PR4^#V'gR#Vh)aHandle exceptions raised during request processing. If we have no exception callback or the callback handled the error or we got a 503, return with an optional timeout so the request can be retried. Otherwise, raise the error. :param error: The exception raised during the request. :param response: The response object. :param exception_cb: Callable to handle the exception. :return: Optional time to wait before retrying the request. NizNEndpoint returned a 503 error. HTTP endpoint is overloaded. Retrying URL (%s).z Retry-After1z7Unable to introspect response header. Waiting 1 second.)rRrNrOr#r]rrIr)rrs&$r% _handle_errorrs" U++ zzzejjC'  > II ===#EMM$5$5mS$IJ J JK  Kr'rrUretries sec_betweenr] headers_cbheaders_redactr check_statusTallow_redirectssessioninfiniteF log_req_resprequest_methodr!streamc<V^8dQhR\R\R\/#)r*rrr:)rrr)r=s"r%r>r>s/m=m=$m=$ %m=&'m=r'c \V4pRVRV/pVP\W44V VR&V'g V'dRMRpVVR&Ve5\V\4'dVVR&M\ \ V4^4VR&Vf.p^pV'd\ \V4^,^4pR \P!4,pVeVP4pM/pV'dVVR &VfRpV f\P!4p \4EFcpV'd V!V4pR V9dVVR &VVR &/pVP4FwppVR 8XdKVR 8XdqV'diVUu.uFpVPV4'gKVNK ppV'd5\P !V4VX&VFp\"VV,V&K KKVVV&K V'd$\$P'R TV 'dRMTVV4V P(!R/VBpV 'dVP+4\$P'RVVP,\/VP04V^,4\3V4u# \IR4huupi \4P6dp\9TTR7ThRp?i\4P:dDp\9TTP<P,TP<P>TR7pTpRp?M6Rp?i\4P@dp\9TTR7pTpRpRp?MRp?ii;i\CTT R7pT'g"T ;'g T^,T8pT'gTThT;'gTp T^8gEKsT'd\$P'RT4\DPF!T 4EK)aWrapper around requests.Session to read the url and retry if necessary :param url: Mandatory url to request. :param data: Optional form data to post the URL. Will set request_method to 'POST' if present. :param timeout: Timeout in seconds to wait for a response. May be a tuple if specifying (connection timeout, read timeout). :param retries: Number of times to retry on exception if exception_cb is None or exception_cb returns True for the exception caught. Default is to fail with 0 retries on exception. :param sec_between: Default 1: amount of seconds passed to time.sleep between retries. None or -1 means don't sleep. :param headers: Optional dict of headers to send during request :param headers_cb: Optional callable returning a dict of values to send as headers during request :param headers_redact: Optional list of header names to redact from the log :param ssl_details: Optional dict providing key_file, ca_certs, and cert_file keys for use on in ssl connections. :param check_status: Optional boolean set True to raise when HTTPError occurs. Default: True. :param allow_redirects: Optional boolean passed straight to Session.request as 'allow_redirects'. Default: True. :param exception_cb: Optional callable to handle exception and returns True if retries are permitted. :param session: Optional exiting requests.Session instance to reuse. :param infinite: Bool, set True to retry indefinitely. Default: False. :param log_req_resp: Set False to turn off verbose debug messages. :param request_method: String passed as 'method' to Session.request. Typically GET, or POST. Default: POST if data is provided, GET otherwise. :param stream: if False, the response content will be immediately downloaded. r#rr POSTGETmethodNrUz Cloud-Init/%srz User-Agentr]z'[%s/%s] open '%s' with %s configurationrz(Read from %s (%s, %sb) after %s attempts)r#rRr]r#r1Please wait %s seconds while we wait to try againz"This path should be unreachable...r4)%r&updaterrKtuplemaxrXr<rversion_stringcopyrSessionr itemsrIdeepcopyrrNrmrequestraise_for_statusrlenrrrSSLErrorr HTTPErrorrr]RequestExceptionrrsleep RuntimeError)!r#rrUrrr]r r rr r rr rrrrreq_args manual_tries user_agentifiltered_req_argskvmatched_headerskeyrr{ url_errorraised_exceptionresponse_sleep_time will_retry sleep_times!&$$$$$$$$$$$$$$$$ r%rrsgj C.C s&H OOM#34"1H  #'U'HX gu % %")HY "%eGna"8HY L3wr>ssU 38   ??  E?   r'cVV'dVPVR7'dR#V!W4#)z Execute func with optional delayrUNwaitr:r;rUr<r=s&&&&&r%_run_func_with_delayrEss( ::e: $ $   r'333333?c V^8dQhR\R\3,R\\,R\R\ R\ \\,\\,3,/#)r*r:. addresses stagger_delayrUr:) r r rr.rXr<rrr)r=s"r%r>r>saP-P- 38 P-CyP-P- P-  8C=(;/ /0 P-r'c RpRpRp.p\P!4p\\V4R7p \ V4U U u/uF'wrV P \ VV VVW,R7V bK) p p p \WR7Fxp W,pV P4pV'dTpVP!V4K9V P4pV'gKSVP4WT3uV PRR7# V'd\PRVV4Vh\PRV4\!R 4huup p i \"dG\PR R P%T4R P%\'\(T444Mi;iT PRR7YT3# T PRR7i;i) aexecute multiple callbacks in parallel Run blocking func against two different addresses staggered with a delay. The first call to return successfully is returned from this function and remaining unfinished calls are cancelled if they have not yet started N) max_workersrDrAFrBzr?rr% enumeratesubmitrEr exceptionappendresultsetshutdownrNrmrrrjoinmapr.)r:rHrIrU return_resultreturned_addresslast_exceptionris_doneexecutorr.r;futuresfuturereturn_exceptions&&&& r% dual_stackr^sM.2NJooG"c)n=H5&%Y/  0 OO$(   0   #7HandledResponse.__annotate__s7 #{##  r'r4N)rrrr__annotate_func__rrrs@r%r`r`sr'r`max_waitinf status_cbr8 sleep_time_cbconnect_synchronously async_delaycV^8dQhR\R\\,R\R\\,R\\,R\R\\\\.\3,,R\ R \ R \/ #) r*rerUrgr r8rrhrrirj)rXrr rr r.r)r=s"r%r>r>s|||e_ |  | " ||$|Hc5\5%89:|| ||r'c aaaaaa a aaaaaaRV3Rllp RRRlloRRloRVV3RlloR VVV 3R lloR VVVVVVV3R llp R V VVV3Rllp\P!4pS'dV'd \R4hV 'dT MTpT;'gT p^oRpV!WWs4pRoVP'd#VPVPP 3#VP 'd.\P!VP 4S^,oRoKV!VS4pS!SVV4'dR#S^,o\PRV4\P!V4\P!4pV'gKVV,VS,8gEKSVV, , pV^8:gEK!R#)aWait for a response from one of the urls provided. :param urls: List of urls to try :param max_wait: Roughly the maximum time to wait before giving up The max time is *actually* len(urls)*timeout as each url will be tried once and given the timeout provided. a number <= 0 will always result in only one try :param timeout: Timeout provided to urlopen :param status_cb: Callable with string message when a url is not available :param headers_cb: Callable with single argument of url to get headers for request. :param headers_redact: List of header names to redact from the log :param sleep_time: Amount of time to sleep between retries. If this and sleep_time_cb are None, the default sleep time defaults to 1 second and increases by 1 seconds every 5 tries. Cannot be specified along with `sleep_time_cb`. :param exception_cb: Callable to handle exception and returns True if retries are permitted. :param sleep_time_cb: Callable with 2 arguments (response, loop_n) that generates the next sleep time. Cannot be specified along with 'sleep_time`. :param request_method: Indicates the type of HTTP request: GET, PUT, or POST :param connect_synchronously: If false, enables executing requests in parallel :param async_delay: Delay before parallel metadata requests, see RFC 6555 :return: tuple of (url, response contents), on failure, (False, None) :raises: UrlError on unrecoverable error c0V^8dQhR\R\/#)r* loop_numberr:)r<rX)r=s"r%r>"wait_for_url..__annotate__sNN3N5Nr'c0<SeS#V^,^,#rr4)_rnr8s&&r%default_sleep_time(wait_for_url..default_sleep_times'3zM9IA9MMr'c<V^8dQhR\R\R\/#)r*re start_timer8)rX)r=s"r%r>ros!   E u r'cV\R4R39dR#V^8*;'g'\P!4V, V,V8#)z4Check if time is up based on start time and max waitrfNF)rXr monotonic)rerur8s&&&r%timeupwait_for_url..timeupsE e d+ +A   NN z )J 6 A r'cV^8dQhR\\,R\\,R\\\,\3,/#)r*rr#r:)rrr.rr)r=s"r%r>ros<'!'!;''!.6sm'! x!3& ''!r'cRpRpV'd V'gRp\\V44pW23#VPP4TP'gCRTP,p\\T4TPTPTR7pY23#TP4'g@RTP,p\\T4TPTPTR7pY23# \P P dOp\TTPPTPPTR7pT\T43uRp?#Rp?ii;i)z?Map requests response code/contents to internal "UrlError" typer!NzRequest timed outrzempty response [%s]zbad status code [%s])rrrr$rrr'rrr]r.rrRr)rr#reasonurl_excr{s&& r%handle_url_response)wait_for_url..handle_url_responses7S(Fz&12G? " #    / / 1   *hmmroDsu* *  E5#(==> > * CcN# *  * " * *  * r'c <RpRpV!V4wrgS !Wv4wrV'g\WgRR7#\\P !4V, 4p S'd RS,MRp RT;'g\ VR R 4: R V : R V : R V: 2p V!V 4\RR\V\4'd\WR 7R7#RR7# \dp RT ,pT pRp ? LRp ? i\dp RT ,pT pRp ? LRp ? ii;i)z:Execute request, handle response, optionally log exceptionr!N)rbzrequest error [%s]zunexpected error [%s]z%ss unlimitedz Calling 'r#z ' failed [r+z]: rr#rrb) r`r Exceptionr<rrwgetattrrKr)rrrurrr|r#rr}r{ time_taken max_wait_str status_msgr~res&&&&& r%read_url_handle_exceptions0wait_for_url..read_url_handle_exceptionsDs  )$/MC1(@OG&sEE)J67 +3ux'  1 177E51 1     zgx00g;      ! )A-FG ,q0FG s)(C D  C(( D 5D 6 DD c<V^8dQhR\R\R\/#)r*r#rUr:)r.r<r)r=s"r%r>rops!   s { r'c ><\TSf/MS!V4SVRSR7#)NF)r]r rUr r)r)r#rUr r rs&&r% read_url_cb!wait_for_url..read_url_cbps- $,B*S/))   r'c$V^8dQhR\/#r9r`)r=s"r%r>rozs"M"M "Mr'c<aRV V3Rllp.pSFp\P!4pS ^8wdbS 'gZS!S V4'd\RRRR7u#S e7S'd/VS,VS ,8d\VS ,V, 4oS!WFWV4pVP'dVu#VP 'gKVP VP 4K V'd \V4MRp \RRV R7#)zliterate over list of urls, request each one and handle responses and thrown exceptions individually per url c$V^8dQhR\/#)r*r#r)r=s"r%r>;wait_for_url..read_url_serial..__annotate__s 4 43 4r'c<VS!VS43#rr4)r#rrUs&r%url_reader_serial@wait_for_url..read_url_serial..url_reader_serialsS'23 3r'Nr)rrwr`r<rrbrPr)rurUrrr wait_timesr#nowoutrbloop_nremust_try_againrrrxrs&f&& r%read_url_serial%wait_for_url..read_url_serialzs 4 4 C.."C{>(J//* 44(w*x*?@":#8C"?@G,! FC||| !!#--0+,(2C Ot 4$)LLr'c$V^8dQhR\/#r9r)r=s"r%r>ros   r'c@<\\SSVR7pS!VSWV4#)zpass list of urls to dual_stack which sends requests in parallel handle response and exceptions of the first endpoint to respond )rIrU)rr^) rurUrrurl_reader_parallelrjrrrs &&&& r%read_url_parallel'wait_for_url..read_url_parallels4 &  %   * z6  r'z3sleep_time and sleep_time_cb are mutually exclusiveNTFr)r)FN) rrwrrr#rrbr)rNrm)rrerUrgr r r8rrhrrirjrrrrru do_read_urlcalculate_sleep_timerrespcurrent_sleep_time current_timer~rrrrrxsfd$$ddd$$d$d @@@@@@r% wait_for_urlrs^NN '!R* * X  "M"MH  !JmNOO16G)>>,>FH : H ===88T]]333 3 ^^^ JJt~~ &aZF!N 1(FC (J(: ; ; " ! ?   %&~~' 7|g- X0EE,";>$2E2E#F#F""Xd.A.A-B#CDDd###GGyy}GGDD GGD EDs$- C B: # C: C C C( c VP'gR#VP4pVf/pW#V&\P!RVP 24;_uu_4\ VPRR7;_uu_4pVP \ P!V44RRR4RRR4R# +'giL;i +'giR#;i)NzWriting wr)rrrrrrtrdumps)rrbvaluecurrs&&& r%update_skew_fileOauthUrlHelper.update_skew_files""" !!# ;CD   $*=*=)>? @ @$   cC C  HHTZZ_ %C @ @C C @ @ @s$ C:&B2 C2 C =C C c\V\4'd#VPR8XgVPR8XgR#RVP9d#\P RVP4R#VPR,p\ P!\V44p\T\ P !4, 4p\TP4PpTPPT^4p\!Yu, 4TP"8d(TP%Ye4\P RYe4YPPT&R# \d"p\P RY$4Rp?R#Rp?ii;i)iiNdatez$Missing header 'date' in %s responsez#Failed to convert datetime '%s': %sz$Setting oauth clockskew for %s to %d)rKrrRr]rNrOrrrrr<rr#netlocrrIabsrr)rrOr remote_timer{skewrbold_skews&& r%rOauthUrlHelper.exception_cbs y( + +3&)..C*?  ** * KK>  O   ( ++io6K ;,- &-->>%%dA. x $"8"8 8  ! !$ - KK> K#t  KK=t G  sE F#E??Fc zVP'g/#Rp\V4PpVP'dGW0P9d7\ \ P !44VPV,,p\ VVPVPVPVPVR7#)N)r#rrrr timestamp) rrrrr<r oauth_headersrrrr)rr#rrbs&& r%r OauthUrlHelper.headers_cb-s~~~I }## >>>dnn4DIIK(4>>$+??I**nn** 00   r'c\VPVPR44VR&\VPVPR44VR&V!V/VB#)r r)r _headers_cbrI _exception_cb)r wrapped_funcrrVs&&&&r%_wrappedOauthUrlHelper._wrapped?s\&   fjj6 |")    > :" ~T,V,,r'c.VP\W4#r)rrrs&*,r%rOauthUrlHelper.wait_for_urlHs}}\488r'c.VP\W4#r)rrrs&*,r%rOauthUrlHelper.readurlKs}}Wd33r'czRpV'd V!V4pVPV4V# TPT4i;i)Tr)rextra_exception_cbrOrets&&& r%rOauthUrlHelper._exception_cbNs> )!(3   i (    i (s '':cj/pV'd V!V4pVPVPV44V#r)rr )rextra_headers_cbr#r]s&&& r%rOauthUrlHelper._headers_cbWs. &s+Gts+,r')rrrrrrrr)NNNNz/run/oauth_skew.json)rrrrrrrrr rrrrrrrrs@r%rrs<#6 &8 $-94r'rc ^RIHpT'd \ T4pMRpTP TTTTTP TR7pTPT4wrp T # \dp\R4ThRp?ii;i)rNzoauth support is not available) client_secretresource_owner_keyresource_owner_secretsignature_methodr)oauthlib.oauth1oauth1 ImportErrorNotImplementedErrorr.ClientSIGNATURE_PLAINTEXTsign) r#rrrrrrr{client_urisigned_headers_bodys &&&&&& r%rr_sK( N  ]]%$*33 F#)++c"2D% # K!"BCJKsA A1 A,,A1)rar)rF )IrrCrirloggingrr>rconcurrent.futuresrrr email.utilsr functoolsr http.clientr itertoolsr sslr typingr r r rrrrrr urllib.parserrrrrr cloudinitrrr getLoggerrrNrrrr&r7rSr}rrrrrWrrrrrrrrEr^r`rXrmrrrr4r'r%r sd   MM!!&   ?>00 ! XzlD&89:"  .D M &< - -3>3 (.( .K.Kb w $!H '+ Fm= m=  m=  m=  m= m=m=m=m=m=m='+m= m=m= !m="#m=$%m=`$P-fj|El| $ | )) | &* ||#'|'+|>B||#'||~||~r'