DUfddlZddlZddlmZddlZddlmZddlm Z ddl Z ddl Z ddl ZddlZddlmZGdde jjZdd Zdd Zd ZdZedZdZdS)N)contextmanagerwraps)utilc6eZdZdefdZedZdZdS)DelimitedTuple,c\||_tj||_dSN)sepclicktypes convert_typetype)selfr rs M/var/www/html/software/conda/lib/python3.11/site-packages/cooler/cli/_util.py__init__zDelimitedTuple.__init__s$K,,T22 cd|jdS)Nz separated[])r )rs rnamezDelimitedTuple.names'DH''''rc||St|tr|d}n|}tfd|DS)Nr c3FK|]}|VdSr )r).0xctxparamrs r z)DelimitedTuple.convert..#s3==!TYYq%--======r) isinstancestrsplittuple)rvaluerrpartss` `` rconvertzDelimitedTuple.convertsd =L s # # KK$$EEE======u======rN)__name__ __module__ __qualname__r!rpropertyrr&rrr r sWS3333((X( > > > > >rr r =cddlm}ddl}|dkr||d}d||dzdz} |||}n*#|j$r}t jd||d}~wwxYw|S)Nr)StringIOr {z: }zError parsing key-value pairs: )ior.yamlreplace safe_load YAMLErrorr BadParameter)argitem_sepkv_sepr.r2resultes rparse_kv_list_paramr<&sKKK3kk(C((  FD)) )C /CQ .. >QQQ !H3!H!HIIqPQ MsA## B -BB Tc|d}|d}t|dkrd}n0t|dkr |d}ntj||r|d}|d}t|dkrd}nt|dkrj t |ddz }n3#t $r&}tjd|dd||d}~wwxYw|dkrtjd |ntj||d}d}d} d} ||d D]} | d\} } n'#t $r}tj||d}~wwxYw| d krt j| } ^| d kr|r| } itjd | d|||| | fS)N:rrr,zNot a number: '') param_hintzField numbers start at 1.r dtypeaggzInvalid property: 'z'.)r"lenrr6int ValueErrornprB)r7includes_colnum includes_aggr%prefixpropsrcolnumr;rBrCitempropr$s rparse_field_paramrO5s- IIcNNE 1XF 5zzQ Uqa %%% S!!Qx u::??FF ZZ1__ U1X*   (1eAh111c zz()DQTUUUU$S)) )Qx E C KK$$ Y YD 5"jjoo ee 5 5 5(--14 5w<()Gt)G)G)GTWXXXX  ##s0-C C6!C11C6E++ F5F  Fctj|d}d|vr|dd\}}tj|st d|d t |}n&#t$r}t d|d|d}~wwxYwt j|d }t j||}ntj|r tj |d gd gd d ti}n2#tj j $r}t d|d||d}~wwxYw|d gdd dgdddd}t#|dt#|d} }tj|| }nt d||fS)Nr?r>)maxsplitzFile "z " not foundz-Expected integer binsize argument (bp), got ""T) all_names )chromstartend)rr?rrU)r namesusecolsrBzFailed to parse bins file "z": last)keeprW)droprlength)rUrW)columns)indexdataz\Expected BINS to be either or :.)op splitdriversplitexistsrFrErread_chromsizesbinnifypdread_csvr!parser CParserErrordrop_duplicates reset_indexrenamelistSeries) r7 arg_nodrivechromsizes_filebinsizer; chromsizesbins chromtablechromslengthss r parse_binsrxds.-$$Q'K k#&::cA:#>#> y)) DBoBBBCC C 'llGG   JJJJ  )/TJJJ |J00 3  Q;///! n DDy% Q Q QH3HH1HHIIq P Q  ' 8 8'59I J [d[ # # VfX>>V ? ?  z&122DH9M4N4NYV':::  9   t s0!A11 B;BB$C>>D-D((D-ct|}|dkrtjdt|t jS)Nrzn_cpus must be >= 1)rErr6minmp cpu_count) arg_values r check_ncpusr~s>IIA~~ !67779blnn---rc#K dVdS#t$r-}|jtjkr ||nYd}~dSd}~wwxYwr )OSErrorerrnoEPIPE)handlerr;s ron_broken_pipersi   7ek ! ! GAJJJJ  JJJJJs A"<Acfd}|S)a Decorator to catch a broken pipe (EPIPE) error and exit cleanly. Use this decorator to prevent the "[Errno 32] Broken pipe" output message. Notes ----- A SIGPIPE signal is sent to a process writing to a pipe while the other end has been closed. For example, this happens when piping output to programs like head(1). Python traps this signal and translates it into an exception. It is presented as an IOError in PY2, and a subclass of OSError in PY3 (aliased by IOError), both using POSIX error number 32 (EPIPE). Some programs exit with 128 + signal.SIGPIPE == 141. However, according to the example in the docs, Python exits with the generic error code of 1 on EPIPE. The equivalent system error when trying to write on a socket which has been shutdown for writing is ESHUTDOWN (108). It also raises BrokenPipeError on PY3. [1] https://docs.python.org/3.7/library/signal.html#note-on-sigpipe [2] https://www.quora.com/How-can-you-avoid-a-broken-pipe-error-on-Python c@tfd}|S)NcT |i|dS#t$r}|jtjkrotjtjtj}tj|tj tj nYd}~dSd}~wwxYwr ) rrrosopendevnullO_WRONLYdup2sysstdoutfilenoexit)argskwargsr;r exit_codefuncs r decoratedz9exit_on_broken_pipe..decorator..decorateds d%f%%%%%   7ek))!gbj"+>>GGGSZ%6%6%8%8999HY''''(''''' s B'BB""B'r)rrrs` r decoratorz&exit_on_broken_pipe..decorators: t       rr+)rrs` rexit_on_broken_pipers$6& r)r r,)TT)rros.pathpathrar contextlibr functoolsrr multiprocessr{numpyrGpandasrgrr ParamTyper r<rOrxr~rrr+rrrs@  %%%%%% >>>>>U[*>>>,    ,$,$,$,$^+++\........r