Ii/SSKrSSKrSSKrSSKJr SSKJrJr SSKJr SSK J r J r J r J r JrJrJrJr SSKJrJr SSKJr SSKJrJr SS KJr SS KJr SS KJrJ r S S K!J"r"J#r#J$r$J%r% S SK&J'r'J(r(J)r)J*r*J+r+J,r,J-r- S SK.J/r/J0r0J1r1 \Rd"S5r3\"SS55r4\ (a\\5r6O\r6"SS\65r7S"SSS\"\#S.S\\4S\8S\\+S\\'S\9S\8S\74Sjjjr:SSS \ \9/\ 4SS4S!jr;g)#N) dataclass)datetime timedelta) attrgetter) TYPE_CHECKINGAnyCallableListOptionalTupleUnioncast)parse_qsurlparse)uuid4)ConnectionPoolRedis)Retry)Sentinel) RedisError WatchError)default_queue_nameexpires_extra_msjob_key_prefixresult_key_prefix) DeserializerJobJobDef JobResult Serializerdeserialize_job serialize_job) timestamp_msto_ms to_unix_mszarq.connectionsc\rSrSr%SrSr\\\\ \\ 44\ S'Sr \ \ S'Sr \\\ S'S r\ \ S 'Sr\\\ S 'Sr\\\ S 'S r\\ S'Sr\\\ S'Sr\\\ S'Sr\\ S'Sr\\\ S'Sr\\\ S'S r\\ S'Sr\ \ S'Sr\ \ S'Sr\ \ S'Sr\\ \ S'S r\\ S'Sr\\ S'S r \\ S'Sr!\\\"\ S 'Sr#\\$\ S!'\%S"\S#S4S$j5r&S#\4S%jr'S&r(g)' RedisSettingsz No-Op class used to hold redis connection redis_settings. Used by :func:`arq.connections.create_pool` and :class:`arq.worker.Worker`. localhosthostportNunix_socket_pathrdatabaseusernamepasswordFssl ssl_keyfile ssl_certfilerequired ssl_cert_reqs ssl_ca_certs ssl_ca_datassl_check_hostnamer conn_timeout conn_retriesconn_retry_delaymax_connectionssentinelmymastersentinel_masterretry_on_timeoutretry_on_errorretrydsnreturnc >[U5nURS;a [S5e[UR5R S5nU(a[ US5nOJURS:wa8UR(a$[ URRS55OSnOSn[UR=(d SUR=(d SURS :HURURUURS:XaURS 9$SS 9$) N>unixredisredisszinvalid DSN schemedbrrH/r*r,rJ)r+r-r2r0r1r/r.)rscheme RuntimeErrorrquerygetintpathlstripr(hostnamer-r0r1)clsrEconfquery_dbr/s 5/venv/lib/python3.13/site-packages/arq/connections.pyfrom_dsnRedisSettings.from_dsn8s} ;;9 934 4DJJ'++D1 8A;'H [[F "59YYs499++C01AHH-+"d x']]]]*.++*?TYY  FJ  cSRSRSURR5555$)NzRedisSettings({})z, c36# UHupUSU<3v M g7f)=N).0kvs rX )RedisSettings.__repr__..Ps3cMbTQqc1%LMbs)formatjoin__dict__items)selfs rX__repr__RedisSettings.__repr__Os/"))$))3cT]]M`M`Mb3c*cddr[r_))__name__ __module__ __qualname____firstlineno____doc__r+r strr r rQ__annotations__r-r.r r/r0r1r2boolr3r4r6r7r8r9r:r<r=r>r?rArBrC ExceptionrDr classmethodrYrj__static_attributes__r_r[rXr(r(s[ /:D%T%S/** +9D#&*hsm*Hc"Hhsm""Hhsm"C!%K#%"&L(3-&#M3#"&L(3-&!%K#%$$L#L#c%)OXc])Hd%OS%"d"04NHT)_-4!E8E?! 3 ?  ,e#er[r(cL^\rSrSrSrSSS\\4S\\S\\ S\\ S\ S\ S \ S S4U4S jjjrSSSSSSS .S \ S\ S\\ S\\ S\\S\S\ \\4S\S\ \\4S\\ S \ S \\4SjjrS\S \4SjrS \\4SjrS\S\ S \4SjrSS.S\\ S \\4SjjrSrU=r$) ArqRedisYa Thin subclass of ``redis.asyncio.Redis`` which adds :func:`arq.connections.enqueue_job`. :param redis_settings: an instance of ``arq.connections.RedisSettings``. :param job_serializer: a function that serializes Python objects to bytes, defaults to pickle.dumps :param job_deserializer: a function that deserializes bytes into Python objects, defaults to pickle.loads :param default_queue_name: the default queue name to use, defaults to ``arq.queue``. :param expires_extra_ms: the default length of time from when a job is expected to start after which the job expires, defaults to 1 day in ms. :param kwargs: keyword arguments directly passed to ``redis.asyncio.Redis``. N pool_or_connjob_serializerjob_deserializerrrkwargsrFc l>X lX0lX@lU(aXS'XPl[TU]"S0UD6 g)Nconnection_poolr_)r{r|rrsuper__init__)rirzr{r|rrr} __class__s rXrArqRedis.__init__fs9- 0"4 (4$ % 0 "6"r[)_job_id _queue_name _defer_until _defer_by_expires_job_tryfunctionargsrrrrrrc # Uc URnU=(d [5Rn [U -n U(aU(a [ S5e[ U5n [ U5n UR SS9IShvN nURU 5IShvN URU [U -5IShvN (a*UR5IShvN SSS5IShvN g[5nUb [U5nOU (aX-nOUnU =(d UU- UR-n [XXXRS9nUR!5 UR#XU5 UR%X:U05 UR'5IShvN SSS5IShvN [+XX0R,S9$GN7GN!GNNNN5![(a SSS5IShvN gf=fNH!,IShvN (df  N]=f7f)a Enqueue a job. :param function: Name of the function to call :param args: args to pass to the function :param _job_id: ID of the job, can be used to enforce job uniqueness :param _queue_name: queue of the job, can be used to create job in different queue :param _defer_until: datetime at which to run the job :param _defer_by: duration to wait before running the job :param _expires: do not start or retry a job after this duration; defaults to 24 hours plus deferring time, if any :param _job_try: useful when re-enqueueing jobs within a job :param kwargs: any keyword arguments to pass to the function :return: :class:`arq.jobs.Job` instance or ``None`` if a job with this ID already exists Nz;use either 'defer_until' or 'defer_by' or neither, not bothT transaction) serializer)rIr _deserializer)rrhexrrNr%pipelinewatchexistsrresetr$r&rr#r{multipsetexzaddexecuterrr|)rirrrrrrrrr}job_idjob_key defer_by_ms expires_mspipeenqueue_time_msscorejobs rX enqueue_jobArqRedis.enqueue_jobws6  11K'EGKK 6) I\] ]I& 8_ ==T=22d**W% % %[[*;f*DEEEjjl"" 322 +nO'"<0'5'#Vu'>AVAV'VJ/^q^qrC JJL KKS 1 IIkE? 3 lln$$+3226;NcNcdd33 %E"3*% 1322, -3222sA8G=:F1;G=>G#F4 G#4F75G#F:G# G="F<#G=(B G#5GF> G G=G!G=4G#7G#:G#<G=>G G G# G=GG=GG#!G=#G:)G, * G:6G=keyc# U[[5SR5n[X URS9nUR 5IShvN nUc[ SUR5S35eX$lU$N,7f)N)rjob " " not found)lenrdecoderr| result_infoKeyErrorr)rirrrrs rX_get_job_resultArqRedis._get_job_resultspS*+-.557&d.C.CD//# # 9U3::<. <= = $sAA9 A7 -A9c# UR[S-5IShvN n[R"UVs/sHo R U5PM sn6IShvN n[ U[ S5S9$NQs snfN7f)z$ Get results for all jobs in redis. *N enqueue_time)r)keysrasynciogatherrsortedr)rirraresultss rXall_job_resultsArqRedis.all_job_resultssdYY03677$(O$Q)=)=a)@$(OPPg:n#=>>8(OPs,A9A0A9A2A9A7A92A9rrc# [UR5-nURU5IShvN nUc[SUS35e[ X@R S9nX%lUR5UlU$NF7f)Nrr) deserializer)rrrPrNr"r|rr)rirrrrbjds rX _get_job_defArqRedis._get_job_defsjv}}.((3-  9se;78 8 Q-B-B CMMO  s,A7A5AA7) queue_namerc # Uc URnURUSSSS9IShvN n[R"UVVs/sH up4UR U[ U55PM" snn6IShvN $NMs snnfN 7f)z; Get information about queued, mostly useful when testing. NTr) withscoresstartend)rzrangerrrrQ)rirjobsrrs rX queued_jobsArqRedis.queued_jobssv  00J[[A2[NN^^ae%faeP]PVd&7&7E &Kae%fgggO%fgs-%A?A5A?'A7 (A?0A=1A?7A?)rrr|r{)rlrmrnrorprrr rr!rrqrQrrrr floatrrrbytesr rr rrrrrv __classcell__)rs@rXrxrxYs 26/337"4 0 #~.#!,##<0 #  #  ## ##*"&%)+/8<7;"&>e>e>e# >e c] >e x( >esE945>ec5)34>e3->e>e #>e@9?tI?sv@Dhx}hV hhr[rx)rDr{r|rr settings_rDr{r|rrrFc^ # Uc [5OUm [T R[5(aT R(a [ S5eT R(aS[ S[ S[4U 4SjjnO[R"[4T RT RT RT RT RT RT RT R T R"T R$T R&T R(T R*T R,T R.S.6nU"T R0T R2T R4SS 9nX'lX7lXGlXWlUR?5IShvN US :a[@RCS 5 U$N!![D[F[H[JRL4anUT RN:a[@RQS T RT RURRRTUT RNU- 5 [JRV"T RX5IShvN US -nSnAO eSnAff=fGM97f)z Create a new redis pool, retrying up to ``conn_retries`` times if the connection fails. Returns a :class:`arq.connections.ArqRedis` instance, thus allowing job enqueuing. NzJstr provided for 'host' but 'sentinel' is true; list of sentinels expectedrr}rFc>[UTRTRS.UD6nURTR[ S9n[ [ U5$)N) sentinelsr2) redis_class)rr+r2 master_forrArxr)rr}clientrIsettingss rX pool_factory!create_pool..pool_factorysR"--LL F %%h&>&>H%UE%( (r[)r+r-r.socket_connect_timeoutr2r3r4r6r7r8r9rDrBrCr>utf8)rKr0r1encodingrzredis connection successfulz;redis connection error %s:%s %s %s, %s retries remaining...r)-r( isinstancer+rqr?rNrrx functoolspartialr-r.r:r2r3r4r6r7r8r9rDrBrCr>r/r0r1r{r|rrpingloggerinfoConnectionErrorOSErrorrr TimeoutErrorr<warningrrlsleepr=) rrDr{r|rrrpoolers @rX create_poolrs2;1Bmo H(--%%(*;*;ghh ) )s )x ) )!((  %66#+#8#8  ,,!.."00!.. ,,'::..%66#22$44! &  $$x/@/@8K\K\gmD#1 $4 !&8 #$4 !))+  "qy 9:K' *g6J6JK x,,,QMMMMKK(())E1 mmH$=$=>>>   sVD7I3;AF1 F/F1I3/F11$I-BI(I I("I3'I((I--I3rIz Redis[bytes]log_funcc # URSS9IShvN nURSS9 URSS9 URSS9 UR5 UR5IShvN up4pVSSS5IShvN WR SS5nWR S S5nWR S S5n U"S US US U SW35 gNNdNS!,IShvN (df  Nh=f7f)NFrServer)sectionMemoryClients redis_version?used_memory_humanconnected_clientszredis_version=z mem_usage=z clients_connected=z db_keys=)rrdbsizerrP) rIrr info_server info_memory info_clients key_countr mem_usageclients_connecteds rXlog_redis_infor.s~~%~00D ( # ( # ) $ BF,,.C?AC.CC.C+C  C+'C.)N)rs<!(SSS+/%+3^^bbb22   , - 8e8e 8eve II@hy@hH*.O+//30,O &O OZ( O |, O  OOOd(C5#::NSWr[