7ThQKSrSSKrSSKrSSKJr SSKJr SSK r SSK r SSK J r SSK r Sr0qSrSrS rS rS rS rS rS%Sjr"SS5r"SS\5r"SS\5r"SS\5r"SS\5rSrSrSrSr Sr!"SS\RD5r#"SS \5r$"S!S"\#5r%"S#S$\5r&g!\a SSKJr Nf=f!\a Sr Nf=f!\a Sr Nf=f!\a Sr Nf=f)&z/Classes and functions for managing compressors.N) LooseVersion)RLock) LZ4FrameFilezMLZ4 is not installed. Install it with pip: https://python-lz4.readthedocs.io/sZFxssBZs7zXZs]s"Mcb[U[5(d[SRU55e[U[5(d[SRU55eUR b[ UR S5(aQ[ UR S5(a6[ UR S5(a[ UR S5(d$[SRUR 55eU[;a!U(d[S RU55eU[U'g) zRegister a new compressor. Parameters ---------- compressor_name: str. The name of the compressor. compressor: CompressorWrapper An instance of a 'CompressorWrapper'. z/Compressor name should be a string, '{}' given.zHCompressor should implement the CompressorWrapper interface, '{}' given.Nreadwriteseektellz^Compressor 'fileobj_factory' attribute should implement the file object interface, '{}' given.z#Compressor '{}' already registered.) isinstancestr ValueErrorformatCompressorWrapperfileobj_factoryhasattr _COMPRESSORS)compressor_name compressorforces I/var/www/auris/envauris/lib/python3.13/site-packages/joblib/compressor.pyregister_compressorr/s os + + = D D_ U   j"3 4 4 %%+VJ%7  !!- J.. 7 7z117;;z116::z116:: ??Ev**@  ,&u>EEoVWW$.L!c2\rSrSrSrSSjrS SjrSrSrg) rXaA wrapper around a compressor file object. Attributes ---------- obj: a file-like object The object must implement the buffer interface and will be used internally to compress/decompress the data. prefix: bytestring A bytestring corresponding to the magic number that identifies the file format associated to the compressor. extension: str The file extension used to automatically select this compressor during a dump to a file. c(XlX lX0lgN)rprefix extension)selfobjrrs r__init__CompressorWrapper.__init__hs" "rNcNUcURUS5$URUSUS9$0Returns an instance of a compressor file object.wb) compresslevelrr fileobjr(s rcompressor_file!CompressorWrapper.compressor_filems3  ''6 6'']'S Src&URUS5$z2Returns an instance of a decompressor file object.rbr)r r+s rdecompressor_file#CompressorWrapper.decompressor_filets##GT22r)rrr)rr) __name__ __module__ __qualname____firstlineno____doc__r"r,r2__static_attributes__rrrrXs # T3rrc8\rSrSr\rSrSrSrS Sjr Sr Sr g) BZ2CompressorWrapperyz.bz2cL[b[RUlgSUlgr)bz2BZ2Filerr s rr"BZ2CompressorWrapper.__init__}s ?#&;;D #'D rc([c [S5eg)Nz;bz2 module is not compiled on your python standard library.)r@rrBs r_check_versions$BZ2CompressorWrapper._check_versionss ;M  rNcnUR5 UcURUS5$URUSUS9$r%rErr*s rr,$BZ2CompressorWrapper.compressor_files?   ''6 6'']'S SrcJUR5 URUS5nU$r/rHr1s rr2&BZ2CompressorWrapper.decompressor_files% &&w5rr)r) r5r6r7r8 _BZ2_PREFIXrrr"rEr,r2r:r;rrr=r=ys! FI(  Trr=c<\rSrSr\rSrSrSrSr S Sjr Sr S r g) LZMACompressorWrapperz.lzma FORMAT_ALONEc[b5[RUl[[UR5UlgSUlgr)lzmaLZMAFilergetattr_lzma_format_name _lzma_formatrBs rr"LZMACompressorWrapper.__init__s1  #'==D 'd.D.D ED #'D rc([c [S5eg)NzO>O'P P''d&7&7 ( rc0[R"US5$r/)rRrSr1s rr2'LZMACompressorWrapper.decompressor_files}}Wd++r)rVrr) r5r6r7r8 _LZMA_PREFIXrrrUr"rEr,r2r:r;rrrNrNs& FI&( ,rrNc \rSrSr\rSrSrSrg)XZCompressorWrapperz.xz FORMAT_XZr;N) r5r6r7r8 _XZ_PREFIXrrrUr:r;rrraras FI#rrac8\rSrSr\rSrSrSrS Sjr Sr Sr g) LZ4CompressorWrapperz.lz4c8[b [UlgSUlgr)lz4rrrBs rr"LZ4CompressorWrapper.__init__s ?#/D #'D rc[c[[5e[RnUR S5(aUSSn[ U5[ S5:a[[5eg)Nvz0.19)rirLZ4_NOT_INSTALLED_ERROR __version__ startswithr)r lz4_versions rrE$LZ4CompressorWrapper._check_versionss[ ;45 5oo  ! !# & &%ab/K  $|F'; ;45 5 = 2.7. If filename is a str or bytes object, it gives the name of the file to be opened. Otherwise, it should be a file object, which will be used to read or write the compressed data. mode can be 'rb' for reading (default) or 'wb' for (over)writing If mode is 'wb', compresslevel can be a number between 1 and 9 specifying the level of compression: 1 produces the least compression, and 9 produces the most compression. 3 is the default. c8[5UlSUlSUl[UlSUlSUlX0l[U[5(aSUs=::aS::dO [SRU55eUS:Xa?[Ul[R"UR 5UlSUlSUlOpUS :Xa[[(Ul[R*"UR[R,UR [R.S5UlO[S U<35e[U[25(a#[4R6"X5UlS Ulg[9US 5(d[9US 5(aXlg[;S5e)NFrrm zS'compresslevel' must be an integer between 1 and 9. You provided 'compresslevel={}'r0rr'zInvalid mode: Trr z1filename must be a str or bytes object, or a file)r_lock_fp_closefp _MODE_CLOSED_mode_pos_sizer(r intrr _MODE_READzlib decompressobjwbits _decompressor_buffer_buffer_offset _MODE_WRITE compressobjDEFLATED DEF_MEM_LEVEL _compressorr ioopenr TypeError)r filenamemoder(s rr"BinaryZlibFile.__init__sAW  !   *---a=6MA6MCCI6-CX  4<#DJ!%!3!3DJJ!?D DL"#D  T\$DJ#//""DMM4::t?Q?QST D 49: : h $ $wwx.DH DM Xv & &'(G*D*DHOP PrcvUR UR[:Xa SSS5 gUR[[4;aSUlONUR[ :Xa:URRURR55 SUl UR(aURR5 SUlSUl [UlSUl SUlSSS5 g!SUlSUl [UlSUl SUlf=f!UR(aURR5 SUlSUl [UlSUl SUlf!SUlSUl [UlSUl SUlf=f=f!,(df  g=f)zFlush and close the file. May be called more than once without error. Once the file is closed, any other operation on it will raise a ValueError. NFrr)rrrr_MODE_READ_EOFrrrr rflushrcloserrrBs rrBinaryZlibFile.close(sM ZZzz\)Z ,::*n!==)-D&ZZ;.HHNN4#3#3#9#9#;<'+D$,}}(#DH$)DM!-DJ#&DL*+D'%Z $DH$)DM!-DJ#&DL*+D',}}(#DH$)DM!-DJ#&DL*+D' $DH$)DM!-DJ#&DL*+D'%ZsMF*A0D&+C: 'F*:)D##F*&F'(+E;(F';)F$ $F''F** F8c(UR[:H$)zTrue if this file is closed.)rrrBs rclosedBinaryZlibFile.closedBszz\))rcVUR5 URR5$)z3Return the file descriptor for the underlying file.)_check_not_closedrfilenorBs rrBinaryZlibFile.filenoGs  xx  rcdUR5=(a URR5$)z)Return whether the file supports seeking.)readablerseekablerBs rrBinaryZlibFile.seekableLs }}6488#4#4#66rcTUR5 UR[[4;$)z/Return whether the file was opened for reading.)rrrrrBs rrBinaryZlibFile.readablePs"  zzj.999rcHUR5 UR[:H$)z/Return whether the file was opened for writing.)rrrrBs rwritableBinaryZlibFile.writableUs  zz[((rcUR(a@[URSS5nSnUbUSRU5- nUS- n[ U5eg)NnamezI/O operation on closed filez {}.)rrTrrr)r fnamemsgs rr BinaryZlibFile._check_not_closed\sQ ;;DHHfd3E0C u||E** 3JCS/ ! rcUR[[4;a&UR5 [R "S5eg)NzFile not open for reading)rrrrrUnsupportedOperationrBs r_check_can_readBinaryZlibFile._check_can_reades6 ::j.9 9  " " $))*EF F :rcxUR[:wa&UR5 [R"S5eg)NzFile not open for writing)rrrrrrBs r_check_can_writeBinaryZlibFile._check_can_writejs1 :: $  " " $))*EF F %rcUR[[4;a&UR5 [R "S5eUR R5(d[R "S5eg)Nz3Seeking is only supported on files open for readingz3The underlying file object does not support seeking)rrrrrrrrrBs r_check_can_seekBinaryZlibFile._check_can_seekose ::j.9 9  " " $))E xx  ""))E #rcUR[:XagUR[UR5:XaUR R =(d URR[5nU(d[eUR RU5UlSUlUR[UR5:XaMg![a [UlURUl gf=f)NFrT)rrrlenrr unused_datarr _BUFFER_SIZEEOFError decompressrr)r rawblocks r _fill_bufferBinaryZlibFile._fill_buffer{s :: '!!S%66 G--99XTXX]]<=X"N  $11<NNuN5f, 6!KLL ! ))#   V  7993ZZs B;C C cUR UR5 URsSSS5 $!,(df  g=f)z!Return the current file position.N)rrrrBs rr BinaryZlibFile.tells& ZZ  " " $99ZZs 3 A) rrrrrrrrrrr(N)r0rz)T)r)r)r5r6r7r8r9r MAX_WBITSrr"rpropertyrrrrrrrrrrrrrrr rr r r:r;rrr|r|s. NNE$QL,4**! 7: )"G G , $ $8 .7& (Trr|c\rSrSrSrSrg)ZlibCompressorWrapperi c@[RU[[SS9 g)Nz.zr!rr)rr"r| _ZLIB_PREFIXrBs rr"ZlibCompressorWrapper.__init__!s"" n\T # rr;Nr5r6r7r8r"r:r;rrrr  rrc\rSrSrSrSrSrg)BinaryGzipFilei'aA file object providing transparent gzip (de)compression. If filename is a str or bytes object, it gives the name of the file to be opened. Otherwise, it should be a file object, which will be used to read or write the compressed data. mode can be 'rb' for reading (default) or 'wb' for (over)writing If mode is 'wb', compresslevel can be a number between 1 and 9 specifying the level of compression: 1 produces the least compression, and 9 produces the most compression. 3 is the default. r;N)r5r6r7r8r9rr:r;rrrr's  Errc\rSrSrSrSrg)GzipCompressorWrapperi8c@[RU[[SS9 g)Nz.gzr)rr"r _GZIP_PREFIXrBs rr"GzipCompressorWrapper.__init__9s"" n\U # rr;Nrr;rrrr8rrr)F)'r9rrjoblib.backportsr threadingr ImportErrordummy_threadingr@ri lz4.framerrRrnr _ZFILE_PREFIXrrrLrdr_rxrrr=rNrarfrrrrrrr|rrrr;rrrs\5 )&& T      $  ! &/R33B,>,-,@$/$ 3,3F    uR&&up  - ^" - ]&%&  C  C  DsDB;C CC); C  C  CCC&%C&)C43C4