]j dZddlZddlZddlmZddlmZddlmZddl m Z m Z m Z m Z mZmZmZddlmZddlmZdd lmZdd lmZmZdd lmZdd lmZdd lm Z ddl!m"Z"ejFejHedZ%e%jMejNddddejPdde dZ)e%jMejNddddejNdde*ejPdde dZ+e%jMejNdde,d !ejNd"d#dd$ejNd%d&dd'ejNd(d)dd*ejNd+d,dd-ejPdde d.Z-e%jMejNd/d0e.1e d2Ze%jMe d3Ze%jMejNdd4d5d67ejNd8d9:ejNd;d<:ejNd=d>:ejNd?d@:ejNdAdB:ejNdCdDdEejNdFdG:ejNdHddIejNdJdKde.LejNdMdNde.dgOejNdPdQ:ejNdRdS:ejNdTddUejPdVejPdWde dXZ/e0dYk(re%yy)Zz 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_registrycy)zRQ command line tool.Nr4/root/env/lib/python3.12/site-packages/rq/cli/cli.pymainr!s rz--allz-aTzEmpty all queues)is_flaghelpqueues)nargsc |r>|jj|j|j|j|}n6|Dcgc]+}|j||j|j|-}}|s*t j dtjd|D]7}|j}t j |d|jd9ycc}w)zEmpty given queues.) connection job_classdeath_penalty_class serializerr!r"r$ Nothing to dorz jobs removed from z queueN) queue_classallr!r"r#clickechosysexitemptyname) cli_configr(rr$optionsqueuenum_jobss rr-r-(s ''++!,, ** * > >! ,     " "*"7"7:CWCWdn #     ?#  G;;= hZ25::,fEFG s0C zRequeue all failed jobsz--queue)requiredtypejob_idsc t||j|j|}|r|j}|s*t j dt jdt j dt|dd}t j|5}|D]} |j|  ddd|dkDrt jd|d d yy#t$r|dz }YRwxYw#1swY?xYw) zRequeue failed jobs.r%r&rz Requeueing z jobs from failed queueNzUnable to requeue z jobs from failed job registryred)fg) rr!r" get_job_idsr)r*r+r,len progressbarrequeuer secho) r/r1r(r"r$r5r0failed_job_registry fail_countjob_ids rr=r=Gs, *//:;O;O\f %113  ?#   JJS\N*ABCJ   7 # w F #++F3  A~ ( 4RSX]^, a    s0C4"C 3C4 C1.C40C11C44C=z --intervalz-iz3Updates stats every N seconds (default: don't poll))r4rz--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 r|rt}n|rt}nt} |r6g} |D].} | j|j | |j 0n&|jj |j } | D]} t| t| t||| |||j|j|j y#t$r4} tj| tjdYd} ~ yd} ~ wt $r,tjtjdYywxYw)zRQ command-line monitor.)r!r7Nr)r r r appendr'r!r(rrr worker_classrr)r*r+r,KeyboardInterrupt) r/intervalraw only_queues only_workersby_queuerr0funcqs queue_namer1es rinforOfs   B$ `  *00 H]H]0^_ `''++z7L7L+MB )E U # !% ( )  dBXz/E/EzG^G^`j`u`u   1      sB+C D6*C>>5D65D6z --durationzBSeconds you want the workers to be suspended. Default is forever.)rr4c |/|dkr*tjdtjdt |j ||rd|d}tj|ytjdy)z/Suspends all workers, to resume run `rq resume`Nr7z*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/durationr0msgs rrrsf 1  ?@  z,,h7)(4  3 jkrc Xt|jtjdy)zCResumes processing of queues, that were suspended with `rq suspend`zResuming workers.N)connection_resumer!r)r*)r/r0s rrrsj++, JJ"#rz-qzThe name of the queue.default)rrVz --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)rrVr4z--retry-intervalz#Interval between retries in seconds)rrWr4rVz --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 argumentsc t|\}}t|||}|xs|}d}| dkDr t| | }t| | }|j |||j }||j ||||||||||| d| }n=|j||||||||||dtj| }|j|||s0tjdt|d|jdyy)z$Enqueues a job from the command lineNr)r$r!z Enqueued z with job-id 'z'.)rrrrr'r! enqueue_call create_jobr SCHEDULED schedule_jobr)r*rid)r/r1timeout result_ttlttl failure_ttl description depends_onrAat_front retry_maxretry_interval schedule_in schedule_atquietr$rXrYr0argskwargsfunction_stringretryschedulejobs renqueuerrs`'y1LD&%hf=O0K E1}i0k;7H  " "5ZJLaLa " bE                                 3)  d?6KSVVTU r__main__)1__doc__r+r)redis.exceptionsrrqrrversionrq.cli.helpersrrrr r r r rq.exceptionsr rq.jobr rq.logutilsr rq.registryrr rq.suspensionrrUrrQrq.utilsrrq.worker_registrationrgroupversion_optionrcommandoptionargumentr-strr=floatrOintrr__name__rrrrs" ,%3;57$8 g   gtT0BC#G$DG6 gtT0IJ i$S1 $_%2K _4 lDu3hi gtT0[\ otT8NO d9PQ lD$5MN#$ORP]jB l!eloplql"$$  i$