o i @s$dZddlZddlZddlmZddlmZddlmZddl m Z m Z m Z m Z mZmZmZddlmZddlmZdd lmZdd lmZmZdd lmZdd lmZdd lm Z ddl!m"Z"e#e$eddZ%e%&ej'dddddej(ddde ddZ)e%&ej'dddddej'dde*dej(ddde dd Z+e%&ej'd!d"e,d#d$ej'd%d&dd'dej'd(d)dd*dej'd+d,dd-dej'd.d/dd0dej(ddde d1d2Z-e%&ej'd3d4e.d5e d6d7Ze%&e d8d9Ze%&ej'dd:d;dd?d@ej'dAdBd@ej'dCdDd@ej'dEdFd@ej'dGdHd@ej'dIdJddKej'dLdMd@ej'dNddOdej'dPdQde.dRej'dSdTde.dgdUej'dVdWd@ej'dXdYd@ej'dZdd[de(d\ej(d]dde d^d_Z/e0d`kre%dSdS)az RQ command line tool N)ConnectionError)Retry) __version__)parse_function_argsparse_schedulepass_cli_configrefresh show_both show_queues show_workers)InvalidJobOperationError) JobStatus)blue)FailedJobRegistryclean_registries)resume)suspend)get_call_string)clean_worker_registrycCsdS)zRQ command line tool.NrrrA/home/app/Keep/.python/lib/python3.10/site-packages/rq/cli/cli.pymain!srz--allz-aTzEmpty all queues)Zis_flaghelpqueues)nargsc sz|rjjjjjd}n fdd|D}|s&tdtd|D]}| }t|d|j dq(dS) zEmpty given queues.) connection job_classdeath_penalty_class serializercs"g|] }j|jjdqS)rrr) queue_classrr).0queue cli_configrrr 7s  zempty.. Nothing to dorz jobs removed from z queueN) r!allrrrclickechosysexitemptyname)r%r(rroptionsr#Znum_jobsrr$rr-(s"   r-zRequeue all failed jobsz--queue)requiredtypejob_idsc Kst||j|j|d}|r|}|stdtdtdt|dd}t |!}|D]} z| | Wq1t yG|d7}Yq1wWdn1sRwY|dkrhtj d|d d d dSdS) zRequeue failed jobs.r r'rz Requeueing z jobs from failed queueNzUnable to requeue z jobs from failed job registryred)Zfg) rrrZ get_job_idsr)r*r+r,lenZ progressbarrequeuer Zsecho) r%r#r(rrr2r/Zfailed_job_registryZ fail_countjob_idrrrr6Gs,      r6z --intervalz-iz3Updates stats every N seconds (default: don't poll))r1rz--rawz-rz)Print only the raw numbers, no bar chartsz --only-queuesz-QzShow only queue infoz--only-workersz-WzShow only worker infoz --by-queuez-RzShows workers by queuec Ks|rt}n|r t}nt}z;|r"g} |D] } | |j| |jdqn|jj|jd} | D] } t| t| q,t ||| |||j|j |jWdSt yd} zt | tdWYd} ~ dSd} ~ wtyvt tdYdSw)zRQ command-line monitor.)rr3Nr)r r r appendr!rr(rrrZ worker_classrr)r*r+r,KeyboardInterrupt) r%intervalrawZ only_queuesZ only_workersZby_queuerr/funcqsZ queue_namer#errrinfofs4     r?z --durationzBSeconds you want the workers to be suspended. Default is forever.)rr1cKs\|dur|dkrtdtdt|j||r'd|d}t|dStddS)z/Suspends all workers, to resume run `rq resume`Nr3z*Duration must be an integer greater than 1zSuspending workers for zb seconds. No new jobs will be started during that time, but then will automatically resumezUSuspending workers. No new jobs will be started. But current jobs will be completed)r)r*r+r,connection_suspendr)r%durationr/msgrrrrs    rcKst|jtddS)zCResumes processing of queues, that were suspended with `rq suspend`zResuming workers.N)connection_resumerr)r*)r%r/rrrrs rz-qzThe name of the queue.default)rrDz --timeoutzWSpecifies the maximum runtime of the job before it is interrupted and marked as failed.)rz --result-ttlz>Specifies how long successful jobs and their results are kept.z--ttlzDSpecifies the maximum queued time of the job before it is discarded.z --failure-ttlz(Specifies how long failed jobs are kept.z --descriptionz!Additional description of the jobz --depends-onzKSpecifies another job id that must complete before this job will be queued.)rmultiplez--job-idzThe id of this jobz --at-frontz@Will place the job at the front of the queue, instead of the endz --retry-maxzMaximum amount of retries)rrDr1z--retry-intervalz#Interval between retries in seconds)rrEr1rDz --schedule-inz8Delay until the function is enqueued (e.g. 10s, 5m, 2d).z --schedule-atzpSchedule job to be enqueued at a certain time formatted in ISO 8601 without timezone (e.g. 2021-05-27T21:45:00).z--quietzOnly logs errors.function argumentscKst|\}}t|||}|p|}d}| dkrt| | }t| | }|j|||jd}|dur?|||||||||||| d| }n|||||||||||dtj | }| |||sjt dt |d|jddSdS)z$Enqueues a job from the command lineNr)rrz Enqueued z with job-id 'z'.)rrrrr!rZ enqueue_callZ create_jobr Z SCHEDULEDZ schedule_jobr)r*rid)r%r#timeoutZ result_ttlttlZ failure_ttl descriptionZ depends_onr7Zat_frontZ retry_maxZretry_intervalZ schedule_inZ schedule_atquietrrFrGr/argskwargsZfunction_stringretryZscheduleZjobrrrenqueuesV 0    "rP__main__)1__doc__r+r)Zredis.exceptionsrZrqrrversionZrq.cli.helpersrrrrr r r Z rq.exceptionsr Zrq.jobr Z rq.logutilsrZ rq.registryrrZ rq.suspensionrrCrr@Zrq.utilsrZrq.worker_registrationrgroupZversion_optionrcommandoptionargumentr-strr6floatr?intrP__name__rrrrs   $          !        , H