_jS %SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK J r SSK r SSK r SSK r SSKrSSKrSSKrSSKJrJr SSKJrJr SSKJrJr SSKJrJr SSKJrJrJ r J!r!J"r"J#r#J$r$J%r%J&r&J'r' SS K(J)r) SSK*r*SSK+r+SS K,J-r-J.r. SS K/J0r0J1r1J2r2J3r3J4r4 SS K5J6r6 SS K7J8r8J9r9J:r:J;r;Jr>J?r? \#(a SSK@JArA SSKBJCrC \R"\E5rF\#(aSSKGJHrH \!\I\4rJ\%SrK\!\I\4rL\'\%S\M4rN\%SrOS\2S3rPS\1S3rQS\2S3rRSrSSrT\RRSS5rWSrXS\YS'SS/rZS \YS!'S"\6S#3r[S$r\\RRS%S&9r_S'r`S\`S(S)S*S+S,S.raS-\YS.'\"S/S09"S1S255rb\"S/S09"S3S455rc\"S/S09"S5S655rd\"S7S855re"S9S:5rf"S;S<5rgS=rhS>riS?rj"S@SA5rk"SBSC5rl"SDSE\m5rn\"SFSG\n55ro\"SHSI\n\p55rqSSJjrr\"SKSL55rs\"SMSN\s55rt\"SOSP\s55ru\"SQSR\s55rv\"S/S09"SSST55rwSUSV/rxSSWjry\"S/S09"SXSY55rzSZr{S[r|S\r}SS]jr~SS^jrS_SS`.SSajjrSbSc.SSdjjrSSejr"SfSg\5rSShjrSSijrSSjjrSSkjr\"SlSm55r\"SnSo55r\SSSpjj5r\SSSqjj5rSSrjrSSsjrS?rStrSur/SvQr/SwQr\+GR("SxSySz9rSS{jr/4SS|jjr/4SS}jjrSSS~jjr/S.SSjjr/S.SSjjrSSjrSSjrSSjrSSjrSSjrSSjrSSjrSSjrSS.SSjjrSS.SSjjrSSjrSS.SSjjrSSjrSS.SSjjrSSjrSSjrSSjrSSjr\"S/S09"SS\w55r\"S/S09"SS\w55r\"S/S09"SS55r\"S/S09"SS55rSSjrSSjrSSSjjrg)) annotationsN)Path)asynccontextmanagercontextmanager)datetimetimezone) dataclassfield)cached_propertypartial) Any AsyncIterator AwaitableDictIterator TYPE_CHECKINGOptionalLiteralCallableUnion) urlencode) aconnect_sse connect_sse)AuthCredentialsFAL_QUEUE_RUN_HOST FAL_RUN_HOSTMissingCredentialsErrorfetch_auth_credentials) __version__)Priorityadd_priority_headeradd_timeout_headeradd_hint_headeradd_fal_app_context_headershandle_response_headersREQUEST_TIMEOUT_TYPE_HEADERREQUEST_TIMEOUT_HEADER)WebSocketClientProtocol) Connection)Image)fal_v3cdnfal)never immediate1h1d7d30d1y)hideforbidallowzhttps:///zwss://zhttps://rest.fal.aizhttps://v3.fal.media FAL_CDN_HOSTzhttps://fal.mediar+UploadRepositoryIdDEFAULT_UPLOAD_REPOSITORYr,r-list[UploadRepositoryId]"DEFAULT_UPLOAD_FALLBACK_REPOSITORYz fal-client/z (python)FAL_CLIENT_EXECUTOR)thread_name_prefix<iiQi: i'i3zdict[str, int | None]#_UPLOAD_LIFECYCLE_EXPIRATION_VALUEST)frozenc*\rSrSr%S\S'S\S'Srg)StorageACLRulelstruserStorageACLDecisiondecisionN)__name__ __module__ __qualname____firstlineno____annotations____static_attributes__rKF/home/rurouni/.local/lib/python3.13/site-packages/fal_client/client.pyrErEls I  rRrEc2\rSrSr%SrS\S'SrS\S'Srg) StorageACLrNzStorageACLDecision | Nonedefaultzlist[StorageACLRule] | NonerulesrK)rLrMrNrOrWrPrXrQrKrRrSrUrUrs)-G &-)-E &-rRrUc@\rSrSr%SrSrS\S'SrS\S'S SjrS r g) StorageSettingsxzLifecycle configuration for uploaded files. Use `expires_in="never"` (or omit `expires_in`) to keep the backend's default retention policy. `expires_in="immediate"` maps to approximately 60 seconds because the backend treats `0` as no expiration. NzObjectExpiration | None expires_inzStorageACL | None initial_aclcJURb[UR5 ggN)r\'_get_upload_expiration_duration_secondsselfs rS __post_init__StorageSettings.__post_init__s ?? & 3DOO D 'rRrKreturnNone) rLrMrNrO__doc__r\rPr]rcrQrKrRrSrZrZxs%+/J'.%)K")ErRrZcH\rSrSr%S\S'S\S'S\S'S\S'S SjrS rg ) CDNTokenrGtoken token_typebase_upload_urlr expires_atcd[R"[R5UR:$r_)rnowrutcroras rS is_expiredCDNToken.is_expireds||HLL)T__< j KL !ZZ44(.  rRc # [R"5IShvN nURURUR0S9IShvN nUR 5 UR 5nSSS5IShvN [WSUSUS[R"US5S9$NNbN4!,IShvN (df  NI=f7fr) r AsyncClientrrrrrrjrrrs rSr#AsyncCDNTokenManager._refresh_tokens$$&&&#[[DMMPR[SSH  % % '==?D'& w-L) ,--d<.@A   'S'&&&sVC B*C )B0 B, $B0. C 9B.:1C ,B0.C 0C6B9 7 CC c&# URIShvN URR5(aUR5IShvN UlURsSSS5IShvN $N]N(N !,IShvN (df  g=f7fr_rras rSrAsyncCDNTokenManager.get_tokensR:::{{%%''$($7$7$99 ;;::9:::sVBA1B3A7 A3 A7 B+A5,B3A75B7B=B > B BrNrrrrKrRrSrrrrRri@i c&\rSrSrSSSS.SSjjr\SSj5r\SSj5r\SSj5rSSSjjr SS jr SS jr \ SSSSS .SS jj5r \ SSSSS .SSjj5rSrg)MultipartUploadN chunk_size content_typemax_concurrencycXlX lX0lU=(d [UlU=(d SUlU=(d [ UlSUlSUl /Ul gNapplication/octet-stream file_name_client_token_managerMULTIPART_CHUNK_SIZErrMULTIPART_MAX_CONCURRENCYr _access_url _upload_id_partsrbrr token_managerrrrs rSrMultipartUpload.__init__S# +$<(<(F,F.K2K'+&*"$ rRcRUR(d [S5eUR$NzUpload not initiatedr ValueErrorras rS access_urlMultipartUpload.access_url#34 4rRcRUR(d [S5eUR$rrrras rS upload_idMultipartUpload.upload_id34 4rRczURR5nURSUR3[S.$N rz User-Agentrrrmrl USER_AGENTrbrls rS auth_headersMultipartUpload.auth_headerss<##--/ % 0 015;;-@$  rRc0URR5nURS3n0URESURUR S.En[ XA5 [URSUUS9nUR5nUSUl USUl gNz/files/upload/multipartr~)rrX-Fal-File-NamePOSTrruploadId) rrrnrrr_object_lifecycle_headers_maybe_retry_requestrrrr)rbobject_lifecycle_preferencerlurlrrresults rScreateMultipartUpload.create s##--/&&''>?  ( --#~~   "'G' LL     !,/ ,rRc URSURSU3n[URSU0UREUR SS.EUSS9nUR SnURRUUS.5 g N /multipart/r8PUTidentity)rzAccept-Encoding)rcontenttimeoutetag) partNumberr) rr_requestrrrrrappend)rb part_numberrrrrs rS upload_partMultipartUpload.upload_part"s!T^^,)concurrent.futuresrmathceillenrfuturesThreadPoolExecutorrrangersubmitr as_completedrr)clsrrrrrrrr concurrent multipartrexecutorrrstartfutures rSsaveMultipartUpload.saveEs3 "'!%+   5PQ #d)i&:&::;    2 2!113 G$Q 2 $qI,@,@@E,@,@$@AOOI$9$9;M 3 %,,99'B C !!##  !!##s .BD D;rrrrc ^^SSKn[RRT5n [RR T5n U"U UUUUUS9mTR US9 [ R"U TR- 5n URRTRS9n /n [SU S-5H,nSUU4SjjnU RU RX55 M. URRU 5HnUR!5 M SSS5 TR#5$!,(df  TR#5$=f)Nrrrrr>c>[TS5nUS- TR-nURU5 URTR5nTR X5 SSS5 g!,(df  g=fNrbr>openrseekreadr)pnfrr file_pathrs rS _upload_part/MultipartUpload.save_file.._upload_parts\i.!!#a9+?+? ?u  vvi&:&:;!--b7 /..s AA'' A5)r$intrfrg)r ospathbasenamegetsizerr r rrrrrrrrrr)rrrr&rrrrrrsizerrrrr'rrs ` @rS save_fileMultipartUpload.save_filels0 "GG$$Y/ wwy)'!%+   5PQ $!5!556    2 2!113 G$Q 2 88x|IJ 3%,,99'B C !!##!  !!##s %A4D11 E rrrrrrrrr)rrGr httpx.Clientrrwr int | Noner str | Nonerr3rfrgrfrGrfdict[str, str]r_r!LifecyclePreferencePayload | Nonerr)rbytesrfrg)rr2rrwrrGrr;rr4rr3rr3rr9)rr2rrwr& str | Pathrr3rr4rr3rr9rfrGrLrMrNrOrpropertyrrrrrr classmethodrr/rQrKrRrSrrs"&#'&*%% % ' %  %!%$% %(     PT-+L-, 0 $(!%&*IM$$$$' $$  $$  $$!$$$$$$$&G$$$$L"&#'&*IM)$)$' )$  )$  )$!)$$)$&G)$ )$)$rRrc*\rSrSrSSSS.SSjjr\SSj5r\SSj5r\SSj5rSSSjjr SS jr SS jr \ SSSSS .SS jj5r \ SSSSS .SSjj5rSrg)AsyncMultipartUploadNrcXlX lX0lU=(d [UlU=(d SUlU=(d [ UlSUlSUl /Ul grrrs rSrAsyncMultipartUpload.__init__rrRcRUR(d [S5eUR$rrras rSrAsyncMultipartUpload.access_urlrrRcRUR(d [S5eUR$rrras rSrAsyncMultipartUpload.upload_idrrRc# URR5IShvN nURSUR3[S.$N&7frrrs rSr!AsyncMultipartUpload.auth_headerssG))3355 % 0 015;;-@$  6sA A'A cx# URR5IShvN nURS3nURIShvN n0UESURUR S.En[ XQ5 [URSUUS9IShvN nUR5nUSUl USUl gNNrN-7fr) rrrnrrrr_async_maybe_retry_requestrrrr)rbrrlrrrequest_headersrrs rSrAsyncMultipartUpload.creates))3355&&''>?)))  ( --#~~   "/O3 LL  #    !,/ ,%6) s4B:B4"B:B6AB: B8 *B:6B:8B:c 4# URSURSU3nURIShvN n[URSU0UEUR SS.EUSS9IShvN nUR SnURRUUS.5 gNcN47fr) rrr_async_requestrrrrr)rbrrrrrrs rSr AsyncMultipartUpload.upload_parts!T^^,# US- TR-nTXTR-nTRX5IShvN gN7f)Nr>)rr)rrchunkrrs rSr.AsyncMultipartUpload.save..upload_partsC 1_ (<(<E'' ; ; ;s8AAAr>c># TIShvN UIShvN SSS5IShvN gNNN !,IShvN (df  g=f7fr_rKtasksems rSbounded_upload1AsyncMultipartUpload.save..bounded_upload#)s sssssEA *A 0,0 A .A 0A A9 AA rr)rfrg) rr r r rrr create_task Semaphorergatherr)rrrrrrrrrrrrtasksr\rZrr[s ` @@rSrAsyncMultipartUpload.saves'!%+  ;VWWW #d)i&:&::; < < %Q 2 2     K 8 92   9 9: nnF~d3FGGG'')))+ X GG)sLDDA D.&D# [TS5nUS- TR-nURU5 URTR5nTR X5IShvN SSS5 gN !,(df  g=f7frr )rr%rrr&rs rSr3AsyncMultipartUpload.save_file..upload_partCsni&!$qI,@,@@u vvi223++K>>> '&? '&s/ BAA3#A1$A3( B1A33 B=Br>c># TIShvN UIShvN SSS5IShvN gNNN !,IShvN (df  g=f7fr_rKrYs rSr\6AsyncMultipartUpload.save_file..bounded_uploadRr^r_r`)r*r+r,r-rr r rrrrarbrrcr)rrrr&rrrrrr.rrrrdr\rZrr[s ` @@rSr/AsyncMultipartUpload.save_file*s2GG$$Y/ wwy)'!%+  ;VWWW $!5!556 ? ? %Q 2 2     K 8 92   9 9: nnF~d3FGGG'')))/ X GG)sOAE !D:"AE #&D< ?? "-dll^8D Ddoo..? ~XV VrRrKr5)rLrMrNrOrPr~rxrQrKrRrSr{r{js N $J $WrRr{c UR5 g![RanSnURnUR 5nO![ a SnOf=f[ U[5(a-URSUR5nURS5nUcURRS5n[UUR[UR5UUS9UeSnAff=f)Ndetailrvzx-fal-error-type)rrv) rrHTTPStatusErrortextrr isinstancedictgetrrqrs)rexcrvmsgbodys rS_raise_for_statusrvs!!#   mm ==?D D  dD ! !((8X]]3C,/J  !))--.@AJ    !! "!  !s8C)C$AC$ AC$ABC$$C)c\rSrSrSrg)StatusirKNrorKrRrSrrsrRrc$\rSrSr%SrS\S'Srg)QueuedizIndicates the request is enqueued and waiting to be processed. The position field indicates the relative position in the queue (0-indexed).r)positionrKN)rLrMrNrOrhrPrQrKrRrSrrsGMrRrc2\rSrSr%Sr\"5rS\S'Srg) InProgressizIndicates the request is currently being processed. If the status operation called with the `with_logs` parameter set to True, the logs field will be a list of log objects.list[dict[str, Any]] | NonelogsrKN) rLrMrNrOrhr rrPrQrKrRrSrrs ).D %/rRrcv\rSrSr%Sr\"5rS\S'\"5rS\S'\"SS9r S \S '\"SS9r S \S 'S r g) Completedia&Indicates the request has been completed and the result can be gathered. The logs field will contain the logs if the status operation was called with the `with_logs` parameter set to True. Metrics might contain the inference time, and other internal metadata (number of tokens processed, etc.).rrdict[str, Any]metricsN)rWr4errorrvrK) rLrMrNrOrhr rrPrrrvrQrKrRrSrrs@ ).D %/#gG^%d+E:+"40J 0rRrcl\rSrSr%S\S'\"SS9rS\S'\"SS9rS\S'\"SS9rS\S'S S jr S r g ) _BaseRequestHandleirGr~Frepr response_url status_url cancel_urlcUSS:Xa [USS9$USS:Xa [USS9$USS:Xa?URS 05n[USUURS 5URS 5S 9$[ S US35e)NstatusIN_QUEUEqueue_position)r IN_PROGRESSr)r COMPLETEDrrrv)rrrrvzUnknown status: )rrrrr)rbrrs rS _parse_status _BaseRequestHandle._parse_statuss >Z '4(8#9: : (^} ,4<0 0 (^{ *hhy"-G&\hhw'88L1  /X/?@A ArRrKN)rAnyJSONrfr) rLrMrNrOrPr rrrrrQrKrRrSrrs:O5)L#)'J''J'BrRr workflowscomfycSSKnURS5n[U5S:aU$URSU5nU(aUR 5upEUSU3$[ SUS35e)Nrr8r>z^([0-9]+)-([a-zA-Z0-9-]+)$zInvalid app id: z*. Must be in the format /)resplitr matchgroupsr)idrrr app_ownerapp_ids rS_ensure_app_id_formatrsk HHSME 5zA~ HH2B 7E !LLN AfX&& 't+UV WWrRcR\rSrSr%S\S'S\S'S\S'S\S'\S Sj5rS rg ) AppIdirGowneraliasr}r+ namespacec [U5nURS5nUS[;a-U"USUSSRUSS5=(d SUSS9$U"USUSSRUSS5=(d SSS9$)Nr8rr>)rrr+r)rrAPP_NAMESPACESjoin)r endpoint_id normalized_idrs rSfrom_endpoint_idAppId.from_endpoint_ids-k: ##C( 8~ %AhAhXXeABi(0D(  ((%)$,   rRrKN)rrGrfr)rLrMrNrOrPr?rrQrKrRrSrrs* J J   rRrr[gV@)r>rAcUR(aURS3OSnUR(aSUR3OSnUURSURU3$)Nr8r{)rr+rr)rprefixsuffixs rS_format_app_pathrsX'-'7'7  ! #RF"(++q 2FXfll^1V\\N6( ;;rRcpUcg[upXs=::aU::dO [SUSUS35e[U5$)Nzmax_buffering must be between z and z (inclusive))REALTIME_MAX_BUFFERINGrrG)value min_value max_values rS_serialize_max_bufferingr sH }1I  +) +,YKuYK| T   u:rRr{r+ max_bufferingc[RU5n[U5n[U3nU(aUSUR S5-- n0nU(aXS'[ U5nUbXS'U(aUS[ U53$U$)Nr8 fal_jwt_tokenr?)rrrREALTIME_URL_FORMATlstriprr) applicationrlr+rrapp_pathrqueryserialized_bufferings rS_build_runner_ws_urlrs # #K 0F'H !( ,C  sT[[%%%E !&o3MB'!5o a %()** JrRrealtimer+c[UUUUS9$)Nr)r)rrlrr+s rS_build_realtime_urlr,s  #  rRc[U[5(aU$[U[5(aR[URS5[5(aUS$[URS5[5(aUS$[ S5e)Nrlrz)Unexpected realtime token response format)rrGrr RuntimeError)rs rS_parse_token_responser;sm$ $ dhhw' - -= dhhx(# . .> ! B CCrRcB^\rSrSrSrSSU4SjjjrSrU=r$) RealtimeErroriFz9Raised when the realtime endpoint sends an error payload.c>XlU=(d SUlU=(d 0UlUR(dUOUSUR3n[TU]U5 g)Nr{z: )rreasonpayloadsuperr)rbrrrrr __class__s rSrRealtimeError.__init__IsI  l }" #{{%5'DKK=0I !rR)rrr)NN)rrGrr4rzOptional[dict[str, Any]])rLrMrNrOrhrrQ __classcell__)rs@rSrrFs4C ",0 " " "* " "rRrc*SSKnURUSS9$)NrF)raw)msgpackunpackbrrrs rSmsgpack_decode_messagerVs ??7? ..rRc*SSKnURUSS9$)NrT) use_bin_type)rpackbrs rSmsgpack_encode_messager\s ==t= 44rRc[U[5(aUR5n[U[[45(aU=(d [ nU"U5$[U[ 5(ac[R"U5nURS5nUS:Xa,[URSS5URS5U5eUS:XagU$S U0$![Ra SUS.s$f=f) Nr)typerrz x-fal-errorr UNKNOWN_ERRORrz x-fal-messager) r memoryviewtobytesr; bytearrayrrGrloadsJSONDecodeErrorrr)rrdecode_messagedecodermsg_types rS_decode_realtime_messagerbs':&&//#'E9-..9#9g'3 8jj)G;;v& } $ G_5 H%   & w ## 8"w7 7 8s.CC0/C0c0U=(d [nU"U5$r_)r)rrencode_messageencodes rS_encode_realtime_messagers 55F '?rRcr\rSrSr%SrS\S'SrS\S'SrS\S 'SS jrSS jr SS jr SS jr SSjr Sr g)RealtimeConnectioniz(Synchronous realtime connection wrapper.z 'Connection'_wsNCallable[[Any], bytes] | None_encode_messageCallable[[bytes], Any] | None_decode_messagecd[XR5nURRU5 gr_rrrsendrb argumentsrs rSr RealtimeConnection.sends"*96J6JK  grRcURR5n[XR5nUcM6U$![aInSSKJnJn [ X$5(aSnAg[ X#5(a[S[U55UeeSnAff=fNr)ConnectionClosedConnectionClosedOKCONNECTION_CLOSED rrecv Exceptionwebsockets.exceptionsrrrrrGrr rbrrrrdecodeds rSrRealtimeConnection.recvs 88==?/x9M9MNGN  c66c44'(;SXFCO s9 B B 'BB cb[URSS5n[U5(aU"5 ggNclosegetattrrcallablerbrs rSrRealtimeConnection.closes''40 E?? G rRcU$r_rKras rS __enter__RealtimeConnection.__enter__s rRc$UR5 gr_rrbexc_typertbs rS__exit__RealtimeConnection.__exit__s  rRrKrrrfrgrfdict[str, Any] | Nonere)rfr)rLrMrNrOrhrPrr r rrr%r,rQrKrRrSrrs:2 59O2959O29( rRrcr\rSrSr%SrS\S'SrS\S'SrS\S 'SS jrSS jr SS jr SS jr SSjr Sr g)AsyncRealtimeConnectioniz)Asynchronous realtime connection wrapper.z'WebSocketClientProtocol'rNrrrr c# [XR5nURRU5IShvN gN7fr_r r s rSr AsyncRealtimeConnection.sends+*96J6JKhhmmG$$$s 4><>c:# URR5IShvN n[XR5nUcM>U$N ![aInSSKJnJn [ X$5(aSnAg[ X#5(a[S[U55UeeSnAff=f7frrrs rSrAsyncRealtimeConnection.recvs !%0/x9M9MNGN1  c66c44'(;SXFCO sCBAAABA BB'B,'BBBc~# [URSS5n[U5(aU"5IShvN ggN7frrr"s rSrAsyncRealtimeConnection.closes1'40 E??'MM  s 2=;=c# U$7fr_rKras rS __aenter__"AsyncRealtimeConnection.__aenter__s  sc@# UR5IShvN gN7fr_r(r)s rS __aexit__!AsyncRealtimeConnection.__aexit__sjjls rKr.r/re)rfr2)rLrMrNrOrhrPrr r rrr:r=rQrKrRrSr2r2s:3 ""59O2959O29%( rRr2c## SSKJn URUU[SS9nUv SSS5 g!,(df  g=f7f)Nr)radditional_headers open_timeoutmax_size)websockets.syncrconnectREALTIME_OPEN_TIMEOUT)rrrwss rS_connect_sync_wsrHs@'  "*       s>- > ;>c# SSKnURUU[SS9IShvN nU7v SSS5IShvN gNN!,IShvN (df  g=f7f)Nrr@) websocketsrErF)rrrJrGs rS_connect_async_wsrKsV!! "* "  s>A<AA A>AAAA  AAc BUR"X40UD6n[U5 U$r_requestrrmethodrkwargsrs rSrrs$~~f4V4Hh OrRc^# UR"X40UD6IShvN n[U5 U$N7fr_rMrOs rSrPrPs/^^F:6::Hh O;s -+-皙?)irBi)ii^@g>@)rEcrUR[;agSUR;agSUR;agg)z-Tell apart ingress errors from client errors.Fzx-fal-request-idnginxT)rsINGRESS_ERROR_CODESrr)rs rS_is_ingress_errorrZs;#66X---(-- rRcURS:Xa%URR[5(ag[ U5(agUR[ ;dURU;agg)NrUFT)rsrrr&rZ RETRY_CODES)rextra_retry_codess rS_should_retry_responser^-sb s"x'7'7';';#((""{*h.B.BFW.W rRc[U[R5(aBURn[U[R5(a[ UR ;agg[U[R5(ag[U[R[45(a[URU5$g![a gf=f)NFT) rrTimeoutExceptionrNRequestr'rrTransportErrorrrqr^r)rr]rNs rS _should_retryrc@s#u--.. kkG'5==11)W__< #u++,,#--/ABCC%cll4EFF    s?B>> C  C cUS:Xa[USUS- --U5nO [X5nU(aU[R"SS5-n[XR5$)N exponentialrr>g?g?)rrandomuniform) num_retry base_delay max_delay backoff_typejitterdelays rS_get_retry_delayrnVsS}$J! A "67CJ*  S)) u  rR)r]c [S[S-5Hn[XU40UD6s $ [S5e![R[ 4ayn[ Xc5(acU[:aY[U[[SS5n[RSUSUS[U- S35 [R"U5 SnAMeSnAff=f) Nr>reTRetrying request to  due to  ( attempts left)Failed to perform request)r MAX_ATTEMPTSrr HTTPErrorrqrcrn BASE_DELAY MAX_DELAYloggerdebugtimesleeprrrPrr]rQattemptrrms rSrrhsL1,- FC:6: :. 2 33!34 S44<9O(ZM4 *3%xuB|g?U>VVef 5!  s 4CA-CCCc # [S[S-5Hn[XU40UD6IShvN s $ [S 5eN![R[ 4azn[ Xc5(adU[:aZ[USSSS5n[RSUSUS[U- S 35 [R"U5IShvN SnAMeSnAff=f7f) Nr>rSrreTrprqrrrsrt) rrurPrrvrqrcrnryrzrr|rr}s rSrLrLsL1,- 'FvFF F. 2 33G!34 S44<9O(#r=$O *3%xuB|g?U>VVefmmE***  sNCA>ACACA(CCCCCCCctURR5S:XaSUR3$UR$)NkeyzBearer )schemelowerrlr)rs rS_cdn_auth_headerrs4 {{e# %%   rRcHUb[R"U5nX S'X S'gg)NzX-Fal-Object-Lifecyclez!X-Fal-Object-Lifecycle-Preference)rdumps)rrlifecycle_jsons rSrrs2#.$?@-;()7E34 /rRc[U[5(a [S5e[U[5(aUS::a [S5eU$U[;a [U$[S5e)Nz9Boolean values are not valid lifecycle expires_in values.rzBInteger lifecycle expires_in value must be greater than 0 seconds.zwUnsupported lifecycle expires_in value. Use one of: never, immediate, 1h, 1d, 7d, 30d, 1y, or an integer seconds value.)rrurr)rB)r\s rSr`r`sn*d##TUU*c"" ?T 882:>>  Z rRcUcg0nURb[UR5nUbX!S'URb0nURRbURRUS'URR(aAURRVs/sHnUR UR S.PM snUS'U(aX1S'U=(d S$s snf)Nexpiration_duration_secondsrW)rHrJrXr])r\r`r]rWrXrHrJ) lifecycle normalizedr acl_payloadrules rS_normalize_upload_lifecyclers-/J'&M  ' # ' 28S4 5(24  ( ( 4%.%:%:%B%BK "  & &&1177$7D >7$K  (3} %  $s"#C!cFU[U5S.nUbX$S'[XC5 U$)N)rrr)rr)rrrrrs rS_cdn_upload_headersrs0 ,>Nt>TUG%.!"gC NrRc<URSSS.n[X!5 U$)Nr~r)rr)rrrs rS_storage_upload_headersrs) **$*G gC NrRc1SknUc[nUc[nO[U[5(dU/nU/UQn/nUH/nXR;a[ SUS35eXT;dMUR U5 M1 U$)N>r,r-r+zUnsupported upload repository '')r;r=rlistrr) repositoryfallback_repositoryallowedordereddedupedentrys rS_normalize_upload_repositoriesrs'G. "@ +T 2 2230/0G(*G  >ugQGH H   NN5 !  NrRcU=(d SUS.$)N upload.binrrrKrs rS_storage_upload_payloadr s.,$ rRrc [US[S3[XC5[X5S9nUR 5nUSnUSn [USUUSU0SS9 U $ Nrz)/storage/upload/initiate?storage_type=gcs)rr upload_urlfile_urlrr)rrr)rrrrr rrrrrr init_response init_resultrrs rS_upload_via_storagersy) *=> $Y ='J M $$&K\*J:&H .  OrRc # [US[S3[XC5[X5S9IShvN nUR 5nUSnUSn [USUUSU0SS9IShvN U $N8N7fr)rLrrrrrs rS_async_upload_via_storager0s5 *=> $Y ='J M $$&K\*J:&H $ .   O%s!*A)A%1A)A'A)'A)cP[US[S-UUS9nUR5S$Nrz /files/upload)rrr)rCDN_URLrrrrrs rS _upload_v3rNs5 $/! H ==?< ((rRc d[US[S-U[XXE5S9nUR5S$r)rFAL_CDN_FALLBACK_URLrrrrrrrrrs rS _upload_cdnr^s?$.#   H ==?< ((rRcl# [US[S-UUS9IShvN nUR5S$N7fr)rLrrrs rS_async_upload_v3rssB 0/! H ==?< ((s 424c # [US[S-U[XXE5S9IShvN nUR5S$N7fr)rLrrrrs rS_async_upload_cdnrsL0.#   H ==?< ((s "><>c [U5Hunup#U"5s $ [ S5e![a>nU[U5S- :ae[R SUXS-SU5 SnAMbSnAff=fNr>z+Upload failed to %s, falling back to %s: %srzUpload attempts were exhausted) enumeraterr rywarningr)attemptsidxlabelr~rs rS_try_upload_with_fallbackrs"+8!4 e 9 "5 7 88 c(ma'' NN=q!!$    s+ A33A..A3c J# [U5H9unup#U"5n[R"U5(a UIShvN s $Us $ [S5eN![a>nU[ U5S- :ae[ R SUXS-SU5 SnAMSnAff=f7fr)rr iscoroutinerr ryrr)rrrr~rrs rS_async_try_upload_with_fallbackrs"+8!4 e YF""6**#|#M "5 7 88$ c(ma'' NN=q!!$    sJB#'AAAB#AB#A B "3BB#B  B#SyncRequestHandlecFUR5 g![a gf=fr_cancelrhandles rS_maybe_cancel_requestrs"      s   AsyncRequestHandlecb# UR5IShvN gN![a gf=f7fr_rrs rS_async_maybe_cancel_requestrs* mmo    s(// ,/,/c\rSrSr%\"SS9rS\S'\SSj5rSS.SSjjr SS S .SS jjr SS jr SS jr Sr g)riFrr2rc[RU5nUR(aURS3OSn[UURSUR SU3nU"UUUS-US-US9$Nr8r{z /requests/z/statusz/cancelr~rrrrrrrQUEUE_URL_FORMATrrrrrr~rrrs rSfrom_request_id!SyncRequestHandle.from_request_id'' 4+1+;+;F$$%Q'&'x ~Qv||nJWaVbc!!)+)+   rR with_logsc[URSURSU0[S9n[ U5 UR UR 55$)Returns the status of the request (which can be one of the following: Queued, InProgress, Completed). If `with_logs` is True, logs will be included for InProgress and Completed statuses.GETrparamsr)rrrQUEUE_POLL_TIMEOUTrrrrbrrs rSrSyncRequestHandle.statussO ( KK  OO '  (#!!(--/22rRrSrintervalc## URUS9nUv [U[5(ag[R"U5 MA7fzContinuously poll for the status of the request and yield it at each interval till the request is completed. If `with_logs` is True, logs will be included in the response. rN)rrrr{r|rbrrrs rS iter_eventsSyncRequestHandle.iter_eventss@[[9[5FL&),, JJx sAAcURSS9HnM [URSUR[S9n[ U5 UR 5$)zOWait till the request is completed and return the result of the inference call.Frrr)rrrrrrrrb_rs rSrSyncRequestHandle.getsS!!E!2A 3( KK 1 1;M  (#}}rRcb[URSUR[S9n[ U5 gzCancel the request.rrN)rrrrrrbrs rSrSyncRequestHandle.cancels*' KK  OO&   (#rRrKN)rr2rrGr~rGrfrrrurfr)rrurr|rfzIterator[Status]rfrrerLrMrNrOr rrPr?rrrrrrQrKrRrSrrs e,FL,        "+03&$)C !  !49 !  ! $rRc\rSrSr%\"SS9rS\S'\SSj5rSS.SSjjr SS S .SS jjr SS jr SS jr Sr g)riFrrlrc[RU5nUR(aURS3OSn[UURSUR SU3nU"UUUS-US-US9$rrrs rSr"AsyncRequestHandle.from_request_idrrRrc# [URSURSU0[S9IShvN n[ U5 UR UR 55$N.7f)rrrrN)rLrrrrrrrs rSrAsyncRequestHandle.status0s\ 4 KK  OO '   (#!!(--/22 s+AA/ArSrc# URUS9IShvN nU7v [U[5(ag[R"U5IShvN MRN?N7fr)rrrrr|rs rSrAsyncRequestHandle.iter_eventsBsQ;;;;;FL&),,--) ) ) ; *s!AA8AAAAc# URSS9ShvN nM N [URSUR[S9IShvN n[ U5 UR 5$7f)z9Wait till the request is completed and return the result.FrNrr)rrLrrrrrrs rSrAsyncRequestHandle.getQsj''%'8 !  84 KK    &     (#}}s+A(A((A(A  A(c~# [URSUR[S9IShvN n[ U5 gN7fr)rLrrrrrs rSrAsyncRequestHandle.cancel_s73 KK  OO&    (#  s (=;=rKN)rrlrrGr~rGrfrr)rrurr|rfzAsyncIterator[Status]rrerrKrRrSrrs %5 1F 1 !       "163&$)C *  *49 *  * $rRc \rSrSr%\"SSS9rS\S'SrS\S '\S,S j5r S,S jr S-S jr \S.S j5r \S/Sj5r S/Sjr\S.S0SjjrSSSS0S.S1SjjrSSSS0SS.S2SjjrSSSSSS0SSS. S3SjjrS4SjrSS.S5SjjrS6SjrS7SjrSSS.S8S jjrS9SSSS!.S:S"jjjrSSSS!.S;S#jjrSS(jj5r\S%SS\S).S?S*jj5rS+rg)@rijNFrWrr4rrVr|default_timeoutc\URc [5$[SUR5$NKeyrrrras rSrAsyncClient._autho& 88 )+ +udhh//rRcUR$r_rras rS _get_authAsyncClient._get_authu zzrRcUR5nURR5S:wa [S5eUR$NrzZKey credentials are required for this operation. Set FAL_KEY or FAL_KEY_ID/FAL_KEY_SECRET.r rrrrlrs rS_get_keyAsyncClient._get_keyx?~~ ;;   % ')l zzrRc4[UR55$r_)rr ras rSrAsyncClient._token_managers#DNN$455rRcUR5n[R"UR[S.UR S9$)Nrrr)r rrrrrrs rSrAsyncClient._clients=~~  !%!2!2(((   rRc# URR5IShvN n[R"URSUR 3[ S.URS9$NC7fNrrr)rrrrrmrlrrrs rS_get_cdn_clientAsyncClient._get_cdn_clients`))3355  $)$4$4#5Qu{{m!D(((   6sA&A$AA&token_expirationc# [RU5R/US.n[URS[ S3US9IShvN n[ UR55$N7fN) allowed_appsrrz/tokens/)r)rrrrLrrrrrbrrrrs rS_get_realtime_tokenAsyncClient._get_realtime_tokensh#33K@FFG 0 4 LL j !    %X]]_55  sAA&A$A&r{r+r start_timeouthintrc R# [U-nU(aUSURS5-- n0UEn Ub [Xi5 Ub [XY5 [ U 5 [ UR SUUUU S9IShvN n [U 5 [U R5 U R5$N47f)a,Run an application with the given arguments (which will be JSON serialized). The path parameter can be used to specify a subpath when applicable. This method will return the result of the inference call directly. Args: timeout: Client-side HTTP timeout in seconds. Controls how long the HTTP client waits for a response. Defaults to the client's default_timeout. start_timeout: Server-side request timeout in seconds. Limits total time spent waiting before processing starts. Does not apply once the application begins processing. r8Nrrrr) RUN_URL_FORMATrr#r"r$rLrrr%rr rbrrr+rr&r'rrrrs rSrunAsyncClient.runs*{*  3S)) )C#.g;   D +  $ } 7#H-3 LL      (# 0 01}} sA.B'0B%15B'r+r' webhook_urlpriorityrr&c # [U-n U(aU SURS5-- n UbU S[SU05-- n 0UEn Ub [XJ5 Ub [ Xj5 Ub [ X5 [ U 5 [URSU UURU S9IShvN n [U 5 [U R5 U R5n [U SU SU S U S URS 9$NW7f) aSubmit an application with the given arguments (which will be JSON serialized). The path parameter can be used to specify a subpath when applicable. This method will return a handle to the request that can be used to check the status and retrieve the result of the inference call when it is done. Args: start_timeout: Server-side request timeout in seconds. Limits total time spent waiting before processing starts (includes queue wait, retries, and routing). Does not apply once the application begins processing. r8Nr fal_webhookrr)r~rrrr)rrrr#r!r"r$rLrrrr%rrr rbrrr+r'r/r0rr&rrrrs rSrAsyncClient.submits,,  3S)) )C  " 3M;#?@@ @C#.g;   D +    3  $ } 7#H-3 LL  ((    (# 0 01}}!L)n-L)L)<<    sBC8C6AC8 r+r'r on_enqueueon_queue_updater0rr&client_timeoutc ^^^^^^^^^^ ^ ^# U b-T cU m O'T U :a![R"ST SU S3[SS9 S/mS UUUU UUUUUUU U4 Sjjn U cU "5IShvN $[R"U "5U S9IShvN $N'N![R a:n SnTS nUb UR n[U5IShvN [U US 9U eSn A ff=f7f) Subscribe to an application and wait for the result. Args: start_timeout: Server-side request timeout in seconds. Limits total time spent waiting before processing starts (includes queue wait, retries, and routing). Does not apply once the application begins processing. client_timeout: Client-side total timeout in seconds. Limits the total time spent waiting for the entire request to complete (including queue wait and processing). If not set, waits indefinitely. Nstart_timeout ("s) is larger than client_timeout (Ts). The request may timeout on the client before the server-side timeout is reached.r stacklevelc > # T RTTT TT TT S9IShvN nUTS'Tb7T"UR5n[R"U5(a UIShvN T bIUR TS9ShvN nT "U5n[R"U5(dM.UIShvN M:UR 5IShvN $NNjNQN$ N"N7fN)r+r'r0rr&rr)rr~inspect isawaitablerr)rreventrr handle_refrr'r6r7r+r0rbr&rs rS _do_subscribe,AsyncClient.subscribe.._do_subscribeAs;;!+'F#JqM%#F$5$56&&v.. LL*#)#5#5 #5#J%%,U3F**622$ % %-!%%$K &soCC>CCC2C 6C7C :"C C%C &C?CCCC  C CCrrrr~r) warningswarn UserWarningrwait_for TimeoutErrorr~rr{)rbrrr+r'rr6r7r0rr&r8rFer~rrEs``````````` @rS subscribeAsyncClient.subscribes2  %$ . / %m_4VWeVfggg ;?  & & &2  !&( (  ))-/>RR R)S## J]F!#.. 1&999'&%  sTAC"B #C(BB B C BC"$CC CCCcB[RURX5$r_)rrrrbrr~s rS get_handleAsyncClient.get_handleks!11$,, XXrRrc^# URX5nURUS9IShvN $N7fNrrSrrbrr~rrs rSrAsyncClient.statusns,9]]Y]7777s $-+-c`# URX5nUR5IShvN $N7fr_rSrrbrr~rs rSrAsyncClient.resultts%9ZZ\!!!s %.,.cb# URX5nUR5IShvN gN7fr_rSrr\s rSrAsyncClient.cancelxs"9mmos %/-//streamr+rcV# [U-nU(aUSURS5-- n[URSUUUS9IShvN nUR 5ShvN nUR 57v MN2N SSS5IShvN g!,IShvN (df  g=f7faYStream the output of an application with the given arguments (which will be JSON serialized). This is only supported at a few select applications at the moment, so be sure to first consult with the documentation of individual applications to see if this is supported. The function will iterate over each event that is streamed from the server. r8r)rrN)r*rrr aiter_sserrbrrr+rreventsrDs rSstreamAsyncClient.stream|s{*  3S)) )C LL     %//1 #ejjl"  #1      slAB)A8B) BA<A:A<"B8B):A<<B= B)B  B)B&B  B&"B)rrrc:# UR5n[U[5(aURS5n[ U5n[ XE5n [ U5[:aPU SS:XaGUcSnUR5IShvN n [RU URUUUUS9IShvN $SU0n UbX;S'[X5 /n U Hn U S:Xa:UR5IShvN n U RS[[XU S 945 MCU S :Xa0U RS [[ UR"UUUUUS 945 MyU S :XdMU RS [[$UR"UUUUUS 945 M ['U 5IShvN $GNNNN 7f) Upload the given data blob and return the access URL. The content type should be specified as the second argument. Use `upload_file()` or `upload_image()` for convenience. Pass `lifecycle` to control uploaded object expiration and initial ACL settings. utf-8rr+Nrrrrrrrrrrrr,rrrrr-)r rrGrrrr MULTIPART_THRESHOLDrrArrrrr rrrrrrbrrrrrrrresolved_lifecyclerepository_chainrrrrepos rSuploadAsyncClient.uploads&~~ dC ;;w'D8C9   t9* */?/Bh/N ( //11F-22"11#),> 3 "<0  )2% &!'>8:$Dx#3355  0&WU - LL !%)5&/8J  5 LL !%)5&/8J  3%P5X>>>q2"6L?sPBFF)F-F.:F(F)A F AF FFFFFc L# [R"U5upVUcSn[X#5n[RR U5[ :a^USS:XaU[U5nUR5IShvN n [R[U5U URUUS9IShvN $[US5n URU R5U[RR!U5UUUS9IShvN sSSS5 $NNcN!,(df  g=f7fzUpload a local file and return the access URL. Pass `lifecycle` to control uploaded object expiration and initial ACL settings. Nrrr+)r&rrrrr)rrrr) mimetypes guess_typerr*r+r-rqrrrAr/rGrr!rvr#r, rbr+rrr mime_typerrtrsrfiles rS upload_fileAsyncClient.upload_files !++D1  2I9   GGOOD !$7 7 #x/! 8 $  ''**40%$7# % 2 sOA7D$9D :1D$+D,D$>#D(,(9(9TG!+mO$S::b)N ;::;:::sWB#B?B# B!B#$B 2 B#=B>B#B#B# B B  B B#rr+rrc># SnSnU(aURXS9IShvN nO#UR5nUR[S.n[ UUUUS9n [ XS9IShvN n U 7v SSS5IShvN gN\NN !,IShvN (df  g=f7fNrrrr)r#r rrrrK rbrrr+rrrrlrrrGs rS ws_connectAsyncClient.ws_connectYs*.  223E>>#D(,(9(9TG"  '   %S::bH;::;:::sXBA=AB"A?#B&B, B7B8B?BBB B BBrKrfrr5)rfr)rfrlrrGrr)rfrGrrGrrr+rGrOptional[Union[int, float]]r&rr'r4rr7rfr)rrGrrr+rGr'r4r/r4r0Optional[Priority]rr7r&rrfr)rrGrrr+rGr'r4rrur6z1Optional[Callable[[str], None | Awaitable[None]]]r7z4Optional[Callable[[Status], None | Awaitable[None]]]r0rrr7r&rr8rrfr)rrGr~rGrfrrrGr~rGrrurfrrrGr~rGrfrrrGr~rGrfrg) rrGrrr+rGr float | NonerfzAsyncIterator[dict[str, Any]]r_r str | bytesrrGrr4rUploadRepositoryId | Noner4UploadRepositoryId | list[UploadRepositoryId] | NonerStorageSettings | NonerfrG r+ os.PathLikerrrrrrrfrGjpeg r Image.ImagerrGrrrrrrrfrG)rrGrrur+rGrr3rr)rrrrrfz&AsyncIterator[AsyncRealtimeConnection]) rrGrrur+rGrr3rr)rf(AsyncIterator['WebSocketClientProtocol']) rLrMrNrOr rrPrr rr rrrr!REALTIME_TOKEN_EXPIRATION_SECONDSr#r,rrOrSrrrrhrvrrrrrrQrKrRrSrrjs[Du5C5"OU"00 66   !B 66 6 6./359"$///  / - /3// / /l"&'+"$59= = =  =  =  = %=  = 3=  = HHLPT'+"$596:NNN  N  NNFNNN%N N3N4N N`YGL88,/8?C8 8 " $ ###  #  # '#B!% X? 15,0X?X?X? X? . X?X?*X? X?|15,0--. -  -*- -d 15,0 .   * 6 $( A8<8<    " 66 06 $( A    "  2rRrc \rSrSr%\"SSS9rS\S'SrS\S '\S-S j5r S-S jr S.S jr \S/S j5r \S0Sj5r \S1Sj5rS/Sjr\S.S2SjjrSSSS0S.S3SjjrSSSS0SS.S4SjjrSSSSSS0SSS. S5SjjrS6SjrSS.S7SjjrS8SjrS9SjrSSS .S:S!jjrS;SSSS".SSSSS".S?S%jjjr\S&S'S\SSS(.S@S)jj5r\S&SS\S*.SAS+jj5r S,r!g)B SyncClientiwNFrr4rrVr|rc\URc [5$[SUR5$rrras rSrSyncClient._auth|rrRcUR$r_r ras rSr SyncClient._get_authr rRcUR5nURR5S:wa [S5eUR$rrrs rSrSyncClient._get_keyrrRcUR5n[R"UR[S.UR SS9$)NrT)rrfollow_redirects)r rrrrrrs rSrSyncClient._clients>~~||!%!2!2(((!   rRc4[UR55$r_)rwr ras rSrSyncClient._token_managerst~~/00rRc[$r_)EXECUTORras rS _executorSyncClient._executorsrRcURR5n[R"URSUR 3[ S.URS9$r)rrrrrmrlrrrs rSrSyncClient._get_cdn_clientsS##--/||$)$4$4#5Qu{{m!D(((   rRrc[RU5R/US.n[URS[ S3US9n[ UR55$r )rrrrrrrrr"s rSr#SyncClient._get_realtime_tokens[#33K@FFG 0 ( LL j !   %X]]_55rRr{r%c 6[U-nU(aUSURS5-- n0UEn Ub [Xi5 Ub [XY5 [ U 5 [ UR SUUUU S9n [U 5 [U R5 U R5$)aRun an application with the given arguments (which will be JSON serialized). Args: timeout: Client-side HTTP timeout in seconds. Controls how long the HTTP client waits for a response. Defaults to the client's default_timeout. start_timeout: Server-side request timeout in seconds. Limits total time spent waiting before processing starts. Does not apply once the application begins processing. r8rr)) r*rr#r"r$rrrr%rrr+s rSr,SyncClient.runs({*  3S)) )C#.g;   D +  $ } 7#H-' LL     (# 0 01}}rRr.c [U-n U(aU SURS5-- n UbU S[SU05-- n 0UEn Ub [XJ5 Ub [ Xj5 Ub [ X5 [ U 5 [URSU UURU S9n [U 5 [U R5 U R5n [U SU SU SU S URS 9$) a?Submit an application with the given arguments (which will be JSON serialized). Args: start_timeout: Server-side request timeout in seconds. Limits total time spent waiting before processing starts (includes queue wait, retries, and routing). Does not apply once the application begins processing. r8rr2rr)r~rrrr)rrrr#r!r"r$rrrrr%rrrr3s rSrSyncClient.submits(,  3S)) )C  " 3M;#?@@ @C#.g;   D +    3  $ } 7#H-' LL  ((   (# 0 01}} L)n-L)L)<<   rRr5c ^^^^^^^^^^ ^ ^U b-T cU m O'T U :a![R"ST SU S3[SS9 S/mS UUUU UUUUUUU U4 Sjjn U cU "5$TRR U 5n U R U S9$![ RRa1nSnTS nUbURn[U5 [U US 9UeSnAff=f) r:Nr;r<r=rr>c > T RTTT TT TT S9nUTS'TbT"UR5 TbURT S9H nT"U5 M UR5$rA)rr~rr)rrDrrrErr'r6r7r+r0rbr&rs rSrF+SyncClient.subscribe.._do_subscribeM s[[!+!F#JqM%6,,-*#//)/DE#E*E::< rRrrrHr) rIrJrKrrrrrrMr~rr{)rbrrr+r'rr6r7r0rr&r8rFrrNr~rrEs``````````` @rSrOSyncClient.subscribe' s2  %$ . / %m_4VWeVfggg :>    *  ! ? "&&}5 ===8 8!!.. J]F!#.. %f-'&%  s9BC&,CCcB[RURX5$r_)rrrrRs rSrSSyncClient.get_handlet s 00{WWrRrcBURX5nURUS9$rVrWrXs rSrSyncClient.statusw s#9}}y}11rRcDURX5nUR5$r_r[r\s rSrSyncClient.result} s9zz|rRcFURX5nUR5 gr_r_r\s rSrSyncClient.cancel s9 rRrarbc# # [U-nU(aUSURS5-- n[URSXRUS9nUR 5HnUR 5v M SSS5 g!,(df  g=f7frd)r*rrriter_sserrfs rSrhSyncClient.stream sp{*  3S)) )C  LL&#w *jjl"+   s>B*A3* B3 B=BrjcUR5n[U[5(aURS5n[ U5n[ XE5n [ U5[:a@U SS:Xa7UcSnUR5n [RU URUUUUS9$SU0n UbX;S'[X5 /n U Hn U S:Xa2UR5n U RS[[XU S945 M;U S :Xa0U RS [[ UR"UUUUUS 945 MqU S :XdMyU RS [[$UR"UUUUUS 945 M ['U 5$) rlrmrr+rrnrrror,rpr-)r rrGrrrr rqrrrrrrr rrrrrrrs rSrvSyncClient.upload s&~~ dC ;;w'D8C9   t9* */?/Bh/N ( ))+F"''"11#),> ( "<0  )2% &!'>8:$Dx--/  FwO ' LL !%)5&/8J  / LL !%)5&/8J  3%P)22rRc [R"U5upVUcSn[X#5n[RR U5[ :aNUSS:XaE[U5nUR5n [R[U5U URUUS9$[US5n URU R5U[RR!U5UUUS9sSSS5 $!,(df  g=fry)rzr{rr*r+r-rqrrrr/rGrr!rvr#r,r|s rSrSyncClient.upload_file s !++D1  2I9   GGOOD !$7 7 #x/! - $ ;; ''**40%$7#   s *?C33 Dc [R"5nURXbS9 URUR 5SU3UUUS9sSSS5 $!,(df  g=frrrs rSrSyncClient.upload_image' sU"ZZ\V JJvJ -;;!!%$7# \\s 3A A!Trrc## SnSn U(aURXS9n O#UR5n U R[S.n[ XXCS9n [ XS9n [ XUS9v SSS5 g!,(df  g=f7fr)r#r rrrrHrrs rSrSyncClient.realtimeB s}*.  ,,-E>>#D(,(9(9TG!+mO c 3r$N 4 3 3sAA; A*! A;* A84A;rc## SnSnU(aURXS9nO#UR5nUR[S.n[ UUUUS9n [ XS9n U v SSS5 g!,(df  g=f7fr)r#r rrrrHrs rSrSyncClient.ws_connect^ s|*.  ,,-E>>#D(,(9(9TG"  '   c 3rH4 3 3sAA5A$ A5$ A2.A5rKrr5)rfr2)rfrw)rfz%concurrent.futures.ThreadPoolExecutorrr)rrGrrr+rGr'r4r/r4r0rrr7r&rrfr)rrGrrr+rGr'r4rrur6zOptional[Callable[[str], None]]r7z"Optional[Callable[[Status], None]]r0rrr7r&rr8rrfr)rrGr~rGrfrrrr) rrGrrr+rGrrrfzIterator[dict[str, Any]]r_rrrr)rrGrrur+rGrr3rr)rrrrrfzIterator[RealtimeConnection]) rrGrrur+rGrr3rr)rfIterator['Connection'])"rLrMrNrOr rrPrr rr rrrr>rrrr#r,rrOrSrrrrhrvrrrrrrQrKrRrSrrwslDu5C5"OU"00     11 !B 66 6 6./359"$,,,  , - ,3,, , ,f"&'+"$59: : :  :  :  : %:  : 3:  : B6:>B'+"$596:KKK  K  KK4K<K%K K3K4K KZXGL22,/2?C2 2  $ ###  #  # "#:!% X3 15,0X3X3X3 X3 . X3X3*X3 X3|15,0--. -  -*- -d 15,0 .   * 6 $( A8<8<    " 66 &6 $( A    "  rRrc[U[5(aURS5nSUS[R"U5R 53$)zIEncode the given data blob to a data URL with the specified content type.rmzdata:z;base64,)rrGrbase64 b64encoder)rrs rSrr| sE${{7# <.)9)9$)?)F)F)H(I JJrRc[R"U5upUcSn[US5n[UR 5U5sSSS5 $!,(df  g=f)zUEncode a file from the local filesystem to a data URL with the inferred content type.Nrr)rzr{r!rr#)r+r}rr~s rS encode_filer sG''-LI. dD Tdiik9-   s A Ac[R"5nURX!S9 [UR 5SU35sSSS5 $!,(df  g=f)zEEncode a pillow image object to a data URL with the specified format.rrN)rrrrr)rrrs rS encode_imager s=  6 )foo'6&):; s ,A  A)rrurfrg)rrGrfrG)rrrfrG)rr3rfr4) rrGrlr4r+rGrr3rfrG) rrGrlr4rr3r+rGrfrG)rr rfrG)rrr;rfr )rrr rfr;)rrr rrrfr0)rrrrrrfr;r_)rrGrdict[str, str] | Nonerfr)rrGrrrfr) rr2rPrGrrGrQr rfru) rrlrPrGrrGrQr rfru)rrurfru)rrur] list[int]rfru)rrr]rrfru)reF) rhr)rir|rjr|rkzLiteral['exponential', 'fixed']rlrurfr|) rr2rPrGrrGr]rrQr rfru) rrlrPrGrrGr]rrQr rfru)rrrfrG)rr7rr9rfrg)r\ObjectExpirationrfr3)rrrfr9) rrrrGrr4rr9rfr7)rrrr9rfr7)rrrrrfr<)rr4rrGrfr7)rr2rrrr;rrGrr4rr9rfrG)rrlrrrr;rrGrr4rr9rfrG)rr2rr;rr7rfrG)rrlrr;rr7rfrG)rz#list[tuple[str, Callable[[], str]]]rfrG)rz#list[tuple[str, Callable[[], Any]]]rfrG)rrrfrg)rrrfrg)rrrrGrfrG)r+rrfrGr)rrrrGrfrG) __future__rrBrrr r*rzrpathlibrrfr{rrloggingr r contextlibrrrr dataclassesr r functoolsr r typingr rrrrrrrrr urllib.parserrIr httpx_sserrfal_client.authrrrrrfal_client._versionrfal_client._headersr r!r"r#r$r%r&r'websockets.clientr(websockets.sync.connectionr) getLoggerrLryPILr*rGrr:LifecyclePreferencePayloadr)rrIr*rrrrenvironrrr;rPr=rMIN_REQUEST_TIMEOUT_SECONDSrrr_IMMEDIATE_EXPIRATION_SECONDSrBrErUrZrjrwrrqrrrrArrnrqrMr{rrrrrrrrrrrFrrrrrrrrrrrrrr2rHrKrrPrurwrxr\rYTimeoutrrZr^rcrnrrLrrr`rrrrrrrrrrrrrrrrrrrrrrrKrRrSrs "  :'(.   # /,   95   8 $ sCx.34!#s(^ ?@ 67L>+013|nA.  zz~~n6IJ08-8@Eu~"$<M;-y 1     0 0, 1 !#/      >#%:  $!!!  $...  $ E E E  == =""J""J('s$s$l~*~*B Y  !! ! WNLW W<   V  00 0  1 1  1 $BBB0w' X $   6%(! <   $        8         D "L " / 5   "?  > 1  (( (V (( (V/3   ,   /3   , -   "%,/;> '*14@C    % ]]5$7&$&  &BD45B !!!!2 !  !  !.$& 4 4 4 4 ! 4  44>$& 4 4 4 4 ! 4  440 F  F!B F  F"%&:     "C      !B  )M.FJ        "C JFJ        "C < )  )  ) )  ).FJ) ) )  )  )  )"C) )* )  )  ) )  ).FJ) ) )  )  )  )"C) )*9199$9199*   $I$*I$I$X $L$+L$L$^ $IIIX $AAAHK.