h}SrSSKrSSKrSSKrSSKrSSKr\R"\5r /SQr Sr Sr Sr SSjrSSjrS rS r"S S \R$5r"S S\R&5rg)z(Helper functions for documentation, etc.N)s3s3ns3us3agsz0///smart_open.utils.QUESTION_MARK_PLACEHOLDER///c[R"U5nURR5VVs0sH;up#UR[R R :wdM/X#R_M= snn$s snnf![a` [R"U5upEpgO![a 0ss$f=fU(d0s$U[U5*Sn[[X55s$f=fN) inspect signature parametersitemsdefault ParameteremptyAttributeError getargspec TypeErrorlendictzip) kallabler nameparamargsvarargskeywordsdefaultssupported_keywordss J/home/james-whalen/.local/lib/python3.13/site-packages/smart_open/utils.pyinspect_kwargsr s %%h/ " )3399; ; }} 1 1 7 77 D-- ;     7 070B0B80L -D8X I   I!3x=./2C*566 7sFB.A;'A; C+ B&%C+& B72C+6B77 C+#C+*C+c[[U55n[U5Vs/sH o3U;dM UPM nnUR5VVs0sHup5X2;dM X5_M nnnU(a[R SU5 U$s snfs snnf)agCheck which keyword arguments the callable supports. Parameters ---------- kallable: callable A function or method to test kwargs: dict The keyword arguments to check. If the callable doesn't support any of these, a warning message will get printed. Returns ------- dict A dictionary of argument names and values supported by the callable. z*ignoring unsupported keyword arguments: %r)sortedr r loggerwarning)rkwargsrkunsupported_keywordsvsupported_kwargss r check_kwargsr*6s{  x 89'-f~U~!BT9TA~U+1<<>U>!Q=T>UCEYZ  VUs BB BBc8Ub [X5n[X5nU$)aClamp a numeric value to a specific range. Parameters ---------- value: numeric The value to clamp. minval: numeric The lower bound. maxval: numeric The upper bound. Returns ------- numeric The clamped value. It will be in the range ``[minval, maxval]``. )minmax)valueminvalmaxvals rclampr1Ps#(E"  E LcxUcUc [S5eUcSO [U5nUcSO [U5nSU<SU<3$)a?Create a byte range specifier in accordance with RFC-2616. Parameters ---------- start: int, optional The start of the byte range. If unspecified, stop indicated offset from EOF. stop: int, optional The end of the byte range. If unspecified, indicates EOF. Returns ------- str A byte range specifier. z7make_range_string requires either a stop or start valuezbytes=-) ValueErrorstr)startstop start_strstop_strs rmake_range_stringr<jsB( }RSSmUI\rs4yH%x 00r2cURSS5upURSS5up4URSS5upVU[U5[U5[U54$)aExtract units, start, stop, and length from a content range header like "bytes 0-846981/846982". Assumes a properly formatted content-range header from S3. See werkzeug.http.parse_content_range_header for a more robust version. Parameters ---------- content_range: str The content-range header to parse. Returns ------- tuple (units: str, start: int, stop: int, length: int) The units and three integers from the content-range header.  /r5)splitint) content_rangeunitsnumbersrangelengthr8r9s rparse_content_rangerHsW"#((a0NEMM#q)ME++c1%KE #e*c$iV 44r2c[RRUSS9nSnUR[;aFSU;a@[ U;a6[ nUR SU5n[RRUSS9nUcU$URR US5n[RRURURUSS5$)aThis is a hack to prevent the regular urlsplit from splitting around question marks. A question mark (?) in a URL typically indicates the start of a querystring, and the standard library's urlparse function handles the querystring separately. Unfortunately, question marks can also appear _inside_ the actual URL for some schemas like S3, GS. Replaces question marks with a special placeholder substring prior to splitting. This work-around behavior is disabled in the unlikely event the placeholder is already part of the URL. If this affects you, consider changing the value of QUESTION_MARK_PLACEHOLDER to something more suitable. See Also -------- https://bugs.python.org/issue43882 https://github.com/python/cpython/blob/3.13/Lib/urllib/parse.py https://github.com/piskvorky/smart_open/issues/285 https://github.com/piskvorky/smart_open/issues/458 smart_open/utils.py:QUESTION_MARK_PLACEHOLDER F)allow_fragmentsN?r4) urllibparseurlsplitschemeWORKAROUND_SCHEMESQUESTION_MARK_PLACEHOLDERreplacepath SplitResultnetloc)urlsr placeholderrSs r safe_urlsplitrYs*   sE  :BK yy&&3#::S[^:^ 0 kk#{+ \\ " "3 " > 77??; ,D << # #BIIryy$B GGr2c\rSrSrSrSrg) TextIOWrapperc,UcUR5 gg)aLCall close on underlying buffer only when there was no exception. Without this patch, TextIOWrapper would call self.buffer.close() during exception handling, which is unwanted for e.g. s3 and azure. They only call self.close() when there was no exception (self.terminate() otherwise) to avoid committing unfinished/failed uploads. N)close)selfexc_typeexc_valexc_tbs r__exit__TextIOWrapper.__exit__s   JJL r2N)__name__ __module__ __qualname____firstlineno__rc__static_attributes__rer2rr[r[s r2r[cD^\rSrSrSrU4SjrU4SjrSrSrSr U=r $) FileLikeProxy.c0>[TU]U5 X lgr )super__init___FileLikeProxy__inner)r_outerinner __class__s rrpFileLikeProxy.__init__s  r2c>[TU]"U0UD6URR"U0UD6 $!URR"U0UD6 f=f)zExit inner after exiting outer.)rorcrq)r_rr%rts rrcFileLikeProxy.__exit__sI 37#T4V4 LL ! !4 26 2DLL ! !4 26 2s /A c6URR5$r ) __wrapped____next__r_s rrzFileLikeProxy.__next__s((**r2cURR5URUR:waURR5 $$!URUR:waURR5 ff=fr )ryr^rqr{s rr^FileLikeProxy.closesh %##))+||t/// ""$0t||t/// ""$0s A7B)__inner) rfrgrhrirqrprcrzr^rj __classcell__)rts@rrlrls!G3+%%r2rl)rN)NN)__doc__r iologging urllib.parserLwrapt getLoggerrfr#rPrQr r*r1r<rHrYr[ ObjectProxyrlrer2rrsy/    8 $6N <44165.&HR B$$ %E%%%r2