(ph-^SSKrSSKJr SSKJrJr SSKJr "SS5rS S\ S\4S jjr g) N)Optional)InvalidCacheBackendErrorcaches)Confc\rSrSrSS\4SjjrSrSrSrSr S r S r S r S r S rSrSrS\4SjrSrS\S\S\4SjrS\4SjrS\S\\4Sjr\S5r\SS\4Sjj5rSrg)Broker Nlist_keycU=(d [RnURU5UlXlUR 5UlSUlgN)r CLUSTER_NAMEget_connection connectionr get_cachecache_info)selfr s L/var/www/html/venv/lib/python3.13/site-packages/django_q/brokers/__init__.py__init__Broker.__init__ s>0t00--h7 ^^%  c2URUR4$r )r rrs r __getstate__Broker.__getstate__s}}djj((rcUuUlUlURUR5UlUR 5Ulgr )r rrrrr)rstates r __setstate__Broker.__setstate__s4$)! tz--dmm<^^% rcg)z= Puts a task onto the queue :type task: str :return: task id N)rtasks renqueueBroker.enqueues rcg)zI Gets a task from the queue :return: tuple with task id and task message Nr!rs rdequeueBroker.dequeue" rcg)z+ :return: the amount of tasks in the queue Nr!rs r queue_sizeBroker.queue_size) rcg)zA :return: the number of tasks currently awaiting acknowledgement Nr!rs r lock_sizeBroker.lock_size/rcg)z# Deletes the queue from the broker Nr!rs r delete_queueBroker.delete_queue4r,rcg)z Purges the queue of any tasks Nr!rs r purge_queueBroker.purge_queue:r,rcg)zB Deletes a task from the queue :param task_id: the id of the task Nr!rtask_ids rdelete Broker.delete@r(rcg)zg Acknowledges completion of the task and removes it from the queue. :param task_id: the id of the task Nr!r8s r acknowledgeBroker.acknowledgeGr(rcg)z/ Fails a task message :param task_id: :return: Nr!r8s rfail Broker.failNr0rreturncg)z@ Checks whether the broker connection is available :rtype: bool Nr!rs rping Broker.pingUr(rcUR$)z Shows the broker type )rrs rinfo Broker.info\szzrkeyvaluetimeoutc2UR(dgURR[R/5nX;aUR U5 URR [RU5 URR XU5$)zd Saves a cluster statistic to the cache provider :type key: str :type value: str :type timeout: int N)rgetrQ_STATappendset)rrIrJrKkey_lists rset_statBroker.set_statbsczz ::>>$++r2   OOC  t{{H-zz~~c'22rc\UR(dgURRU5$)zY Gets a cluster statistic from the cache provider :type key: str :return: a cluster Stat N)rrM)rrIs rget_statBroker.get_statqs! zz zz~~c""rpatterncUR(dgURR[R5nU(a[ U5S:Xa/$/nUHInURRU5nU(aUR U5 M8UR U5 MK URR[RU5 U$)zi Returns a list of all cluster stats from the cache provider :type pattern: str :return: a list of Stats Nr)rrMrrNlenrOremoverP)rrWrQstatsrIstats r get_statsBroker.get_stats{s zz ::>>$++.3x=A-IC::>>#&D T"$  t{{H- rcR[[R$![a gf=f)z; Gets the current cache provider :return: a cache provider N)rrCACHErr!rrrBroker.get_caches(  $**% %'  s  &&cg)zc Gets a connection to the broker :param list_key: Optional queue name :return: a broker connection rr!r s rrBroker.get_connectionsr)rrrr r )__name__ __module__ __qualname____firstlineno__strrrrr#r&r*r.r2r5r:r=r@boolrDrGintrRrUrlistr] staticmethodrr__static_attributes__r!rrrr s)&           d  3C 3 3c 3#C#$*rrr rBcU=(d [Rn[R(aI[RRSS5up[R "U5n[ X25nU"US9$[R(aSSKJ n URUS9$[[R[5(aSSKJn URUS9$[R (aSSKJn UR!US9$[R$(aSSKJn UR)US9$SS KJn U R-US9$) zu Gets the configured broker type :param list_key: optional queue name :type list_key: str :return: a broker instance .rcr)ironmq)aws_sqs)orm)mongo) redis_broker)rr BROKER_CLASSrsplit importlib import_modulegetattrIRON_MQdjango_q.brokersrr IronMQBroker isinstanceSQSdictrsSqsORMrtMONGOruMongorvRedis) r modulefuncmbrokerrrrsrtrurvs r get_brokerrs,4,,H ((//Q7   # #F +!x(( +""H"55 DHHd # #,{{H{-- (www)) *{{H{-- 2!!8!44rr ) rytypingrdjango.core.cacherr django_q.confrrrirr!rrrs1>YYx&5&5&5r