s,g. dZddlZddlZddlZddlZddlZddlZddlmZddl m Z m Z m Z m Z mZmZmZmZmZe r ddlmZddlmZddlmZdd lmZej6eZd ee d ee fd Zd eee fd e fdZ!d e e e ffdZ"de d e de ffdZ#d ejfdZ$dZ%dejd e fdZ&de d ejfdZ'd6defdZ(de d e)fdZ*de d efdZ+d e,fdZ-d7d efdZ.d eed eejfd!Z/d"eee,e0e fd ee,fd#Z1d$d%d ee,e,e,ffd&Z2d'Z3d(ee d)e,fd*Z4d7d+e d,ee,d e fd-Z5 d7d.ee d/e d0e e e fd,ee,d ee f d1Z6d2eee d3fd ee fd4Z7d2eee d3fd ed%fd5Z8y)8z Miscellaneous helper functions. The formatter for ANSI colored console output is heavily based on Pygments terminal colorizing code, originally by Georg Brandl. N)Iterable) TYPE_CHECKINGAnyCallableDictListOptionalTupleTypeUnion)RedisQueue) ResponseError)TimeoutFormatErrorlstreturnc2|Dcgc]}|| c}Scc}w)zExcludes `None` values from a list-like object. Args: lst (list): A list (or list-like) oject Returns: object (list): The list without None values )ritems b/var/www/trellinator.diamondhoofcare.com/public_html/venv/lib/python3.12/site-packages/rq/utils.pycompactrs! 5TD$4D 55 5svct|tr|jdSt|tr|St dt |z)zConverts a bytes value to a string using `utf-8`. Args: v (Union[bytes, str]): The value (bytes or string) Raises: ValueError: If the value is not bytes or string Returns: value (str): The decoded string zutf-8zUnknown type %r) isinstancebytesdecodestr ValueErrortype)rs ras_textr")sA!Uxx  As *T!W455c,tfdDS)aDecodes the Redis hash, ensuring that keys are strings Most importantly, decodes bytes strings, ensuring the dict has str keys. Args: h (Dict[Any, Any]): The Redis hash Returns: Dict[str, Any]: The decoded Redis data (Dictionary) c3>K|]}t||fywN)r").0khs r z$decode_redis_hash..Gs.qQqT".s)dict)r)s`rdecode_redis_hashr,=s .A. ..r#name.c|jd}|dd|dg}}d}t|r( dj|}tj|} | t|Sdj|}t||r t||S|j}dj|} t||}t||std|zt||S#t $r#|j d|jYnwxYwt|r#t$rtd|zwxYw#td|zxYw)a#Returns an attribute from a dotted path name. Example: `path.to.func`. When the attribute we look for is a staticmethod, module name in its dotted path is not the last-before-end word E.g.: package_a.package_b.module_a.ClassA.my_static_method Thus we remove the bits from the end of the name until we can import it Args: name (str): The name (reference) to the path. Raises: ValueError: If no module is found or invalid attribute name. Returns: Any: An attribute (normally a Callable) .NrzInvalid attribute name: %s) splitlenjoin importlib import_module ImportErrorinsertpop __builtins__KeyErrorr hasattrgetattr) r- name_bitsmodule_name_bitsattribute_bitsmodule module_nameattribute_nameattribute_owner_nameattribute_owners rimport_attributerEJsg& 3I'0"~ " n F   =((#34K,,[9F ~ B% %XXn-Nv~&v~..#'')N88N3H!&*>? ?N 35<== ?N 33/ =  ! !!%5%9%9%; < =   B9D@A A BH5FGGs)&CD) D2)DDD/2EcptjjtjjS)zReturn now in UTC)datetimenowtimezoneutcrr#rrHrHs%    !2!2!6!6 77r#%Y-%m-%dT%H:%M:%S.%fZdtc@|jttSr&)strftimer"_TIMESTAMP_FORMAT)rLs r utcformatrPs 2;;w01 22r#stringc tjj|tS#t$rU tjj|dcYS#t$r%tjj|dcYcYSwxYwwxYw)NrKz%Y-%m-%dT%H:%M:%SZ)rGstrptimerOr )rQs rutcparserTs~L  ))&2CDD L L$$--f6MN N L$$--f6JK K L Ls,#& BAB)B;B?BBiterablecN||D]}|s|cS|S|D]}||s |cS|S)aReturn first element of `iterable` that evaluates true, else return None (or an optional default value). >>> first([0, False, None, [], (), 42]) 42 >>> first([0, False, None, [], ()]) is None True >>> first([0, False, None, [], ()], default='ohai') 'ohai' >>> import re >>> m = first(re.match(regex, 'abc') for regex in ['b.*', 'a(.*)']) >>> m.group(1) 'bc' The optional `key` argument specifies a one-argument predicate function like that used for `filter()`. The `key` argument, if supplied, must be in keyword form. For example: >>> first([1, 1, 3, 4, 5], key=lambda x: x % 2 == 0) 4 Args: iterable (t.Iterable): _description_ default (_type_, optional): _description_. Defaults to None. key (_type_, optional): _description_. Defaults to None. Returns: _type_: _description_ r)rUdefaultkeyels rfirstrZsLB { B   N  B2w   Nr#objcHt|txrt|t S)zReturns whether the obj is an iterable, but not a string Args: obj (Any): _description_ Returns: bool: _description_ )rrrr[s ris_nonstring_iterabler^s  c8 $ AZS-A)AAr#c"t|r|S|gS)zWhen passed an iterable of objects, does nothing, otherwise, it returns a list with just that object in it. Args: obj (Any): _description_ Returns: List: _description_ )r^r]s r ensure_listr`s(,373%7r#ctjtjjtjj j S)zKReturns current UTC timestamp Returns: int: _description_ )calendartimegmrGrHrIrJ utctimetuplerr#rcurrent_timestampres9 ??8,,001B1B1F1FGTTV WWr#cX| t||St|tr t|S|S)aGet a backend class using its default attribute name or an override Args: holder (_type_): _description_ default_name (_type_): _description_ override (_type_, optional): _description_. Defaults to None. Returns: _type_: _description_ )r<rrrE)holder default_nameoverrides r backend_classrjs1v|,, Hc "))r#date_strc:|syt|jSr&)rTr)rks r str_to_daterms )**r#timeoutc<t|tjs| t|}|S|S#t$ret|t sJ|dd|ddj }}ddddd} t|||z}Y|S#ttf$r tdwxYwwxYw) zGTransfer all kinds of timeout format to an integer representing secondsNr0iQi<r)dr)mszTimeout must be an integer or a string representing an integer, or a string with format: digits + unit, unit can be "d", "h", "m", "s", such as "1h", "23m".) rnumbersIntegralintr rlowerr:r)rndigitunit unit_seconds r parse_timeoutr{s gw// 0W5H 'lG N7N gs+ ++!#2,(<(<(>4E %DrBK e*{4'88 N) (+  s -:B(A<<BB connectionr ct t|ddst|jdd}|jdddDcgc] }t |}}t |dkr |j dt |dkr t|dt|t|dScc}w#t$rYywxYw) a/ Returns tuple of Redis server version. This function also correctly handles 4 digit redis server versions. Args: connection (Redis): The Redis connection. Returns: version (Tuple[int, int, int]): A tuple representing the semantic versioning format (eg. (5, 0, 9)) __rq_redis_server_versionNserver redis_versionr/r)r ) r<rinfor1rvr2appendsetattrtupler)r| version_stri version_partss r get_versionrsz#>Ejooh7HIK-8->->s-CBQ-GHSVHMHm$q($$Q'm$q( +m$  z#>??I s*AB+B&/B+!B+&B++ B76B7c| |z S)zCeiling division. Returns the ceiling of the quotient of a division operation Args: a (_type_): _description_ b (_type_): _description_ Returns: _type_: _description_ r)abs rceildivr2sR1W:r#a_list segment_sizec#VKtdt||D] }||||zyw)zSplits a list into multiple smaller lists having size `segment_size` Args: a_list (List[Any]): A list to split segment_size (int): The segment size to split into Yields: list: The splitted listed rN)ranger2)rrrs r split_listr?s61c&k< 0+Q\)**+s')data max_lengthc:||St||kDr|d|dzS|S)aTruncate arguments with representation longer than max_length Args: data (str): The data to truncate max_length (Optional[int], optional): The max length. Defaults to None. Returns: truncated (str): The truncated string Nz...)r2)rrs rtruncate_long_stringrMs1 *-d)j*@D*  %JdJr# func_nameargskwargscr|y|Dcgc] }ttt||"}}|jDcgc]3\}}dj |ttt||5}}}|t |z }dj |}dj ||Scc}wcc}}w)a Returns a string representation of the call, formatted as a regular Python function invocation statement. If max_length is not None, truncate arguments with representation longer than max_length. Args: func_name (str): The funtion name args (Any): The function arguments kwargs (Dict[Any, Any]): The function kwargs max_length (int, optional): The max length. Defaults to None. Returns: str: A String representation of the function call. Nz{0}={1}z, z{0}({1}))r"rrepritemsformatsortedr3) rrrrargarg_listr(r list_kwargss rget_call_stringr\s"PTU,T#Y CDUHUgmgsgsguv_c_`bc9##Aw/CDGZ/X'YZvKv {##H 99X D   Y -- Vvs %B.8B3queues_or_namesrcddlm}g}|D]D}t||r|j|j+|jt |F|S)z6Given a list of strings or queues, returns queue namesrr)queuerrrr-r)rrnames queue_or_names r parse_namesrysM E(- mU + LL++ , LL]+ , - Lr#cRddlm}|D]}t||s|jcSy)z7Given a list of strings or queues, returns a connectionrrN)rrrr|)rrrs rget_connection_from_queuesrs/(, mU + ++ +, r#)NNr&)9__doc__rbrGrLr4loggingrtcollections.abcrtypingrrrrrr r r r redisr rrredis.exceptionsr exceptionsr getLogger__name__loggerrrrr"r,rErHrOrPrTrZboolr^r`rvrerjrmfloatr{rrrrrrrrr#rrs$YYY**   8 $ 6c 6tCy 66uUCZ 6S6( /DcN /243248CH#524j8X  8 ,3"++3#3LSLR[[L*H*Z Bs Bt B 8S 8T 8X3X$&+(5/+hr{{.C+8E#uc/$:; *Gc3m(<<  +tCy + + Ks K K K ^b.}.$'.15c3h.MUVY]. c].: eCL&9!: tCy U3<5H0IhW^N_r#