s,g4AdZddlZddlZddlZddlZddlZddlmZmZm Z m Z ddl Z ddl m Z ddlmZddlmZddlmZmZmZmZmZmZmZmZmZddlmZmZmZm Z m!Z!m"Z"dd l#m$Z$dd l%m&Z&m'Z'dd l(m)Z)dd l*m+Z+m,Z,dd l-m.Z.ddl/m0Z0ddl/m1Z2ddl/m3Z4ddl5m6Z6m7Z7ddl8m9Z9ddl:m;Z;ddlZ>e j~e jedZAeAje jdddde jddedZEeAje jdddd e jd!deF"e jd#ded$ZGeAje jd%d&eHd'(e jd)d*dd+e jd,d-dd.e jd/d0dd1e jd2d3dd4e jdded5ZIeAje jd6d7dd8e jd9eFd:d;<e jd=eFed><e jd?eFed@<e jdAdBdCDe jdEeJe!dF<e jdGeJe"dH<e jdIeJe dJ<e jdKeJedL<e jdMddNe jdOdPddQe jdRdSddTe jdUdVdWe jdXdYDe jdZd[dd\e jd]eJdd^<e jd_eJdd`<e jdadbddce jdddeddfge jdhdidjdkge jddedlZKeAje jdmdneJoedpZ3eAjedqZ1eAje jd!dSdrdjse jdtduDe jdvdwDe jdxdyDe jdzd{De jd|d}De jd~ddWe jddDe jddde jdddeJe jdddeJdge jddDe jddDe jdRdde jde jddedZLeAje jd6d7dd8e jddeFd:d;<e jdOdPddQe jdRdSddTe jd=eFed><e jd?eFed@<e jdeFdd<e jdde jddBeJdd<edeMfdZNeOdk(reAyy)z RQ command line tool N) TYPE_CHECKINGListTypecast)ConnectionError)Retry) __version__) parse_function_argsparse_schedulepass_cli_configread_config_filerefreshsetup_loghandlers_from_args show_both show_queues show_workers)DEFAULT_JOB_MONITORING_INTERVALDEFAULT_LOGGING_DATE_FORMATDEFAULT_LOGGING_FORMAT!DEFAULT_MAINTENANCE_TASK_INTERVALDEFAULT_RESULT_TTLDEFAULT_WORKER_TTL)InvalidJobOperationError)Job JobStatus)blue)FailedJobRegistryclean_registries)DefaultSerializer) is_suspended)resume)suspend)get_call_stringimport_attribute)Worker) WorkerPool)clean_worker_registry) Serializercy)zRQ command line tool.Nr*d/var/www/trellinator.diamondhoofcare.com/public_html/venv/lib/python3.12/site-packages/rq/cli/cli.pymainr-7s r+z--allz-aTzEmpty all queues)is_flaghelpqueues)nargsc |r>|jj|j|j|j|}n6|Dcgc]+}|j||j|j|-}}|s*t j dtjd|D]A}|j}t j dj||jCycc}w)zEmpty given queues.) connection job_classdeath_penalty_class serializerr4r5r7 Nothing to dorz{0} jobs removed from {1} queueN) queue_classallr4r5r6clickechosysexitemptyformatname) cli_configr;r0r7optionsqueuenum_jobss r,r@r@>s ''++!,, ** * > >! ,     " "*"7"7:CWCWdn #     ?#  S;;= 4;;HejjQRS s0C*zRequeue all failed jobsz--queue)requiredtypejob_idsc t||j||}|r|j}|s*tjdt j dtjdjt|d}tj|5}|D]} |j|  ddd|dkDr'tjdj|d yy#t$r|dz }Y]wxYw#1swYJxYw) zRequeue failed jobs.r8r9rz%Requeueing {0} jobs from failed queueNz3Unable to requeue {0} jobs from failed job registryredfg) rr4 get_job_idsr<r=r>r?rAlen progressbarrequeuersecho) rCrEr;r5r7rIrDfailed_job_registry fail_countjob_ids r,rRrR]s, *//9Q[ %113  ?#   JJ6==c'lKLJ   7 # w F #++F3  A~ IPPQ[\afg, a    s0D#C,4D,C=:D<C==DD z --intervalz-iz3Updates stats every N seconds (default: don't poll))rHr/z--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.)r4rKNr)rrrappendr:r4r;rr'r worker_classrr<r=r>r?KeyboardInterrupt) rCintervalraw only_queues only_workersby_queuer0rDfuncqs queue_namerEes r,inford|s   B$ `  *00 H]H]0^_ `''++z7L7L+MB )E U # !% ( )  dBXz/E/EzG^G^`j`u`u   1      sB+C D6*C>>5D65D6z--burstz-bz/Run in burst mode (quit after all work is done)z--logging_levelINFOzSet logging level)rHdefaultr/z --log-formatzSet the format of the logsz --date-formatzSet the date format of the logsz--namez-nzSpecify a different name)r/z --results-ttlz"Default results timeout to be usedz --worker-ttlzWorker timeout to be usedz--maintenance-intervalz1Maintenance task interval (in seconds) to be usedz--job-monitoring-intervalz*Default job monitoring interval to be usedz--disable-job-desc-loggingzTurn off description logging.z --verbosez-vzShow more outputz--quietz-qzShow less outputz--exception-handlerzException handler(s) to use)r/multiplez--pidz;Write the process ID number to a file at the specified pathz#--disable-default-exception-handlerz-dz&Disable RQ's default exception handlerz --max-jobsz!Maximum number of jobs to executez--max-idle-timez5Maximum seconds to stay alive without jobs to executez--with-schedulerz-szRun worker with schedulerz --serializerz-Sz!Run worker with custom serializer)rfr/z--dequeue-strategyz-dsrfz5Sets a custom stratey to dequeue from multiple queuesc |jrt|jni}|xs|jddg}|xs|jd}|jd}|rtjj || r^t t jj| d5}|jtt jddd|jj}|dvrC|dk(rd nd }d |d |d }tj|t t#j$|d|dvr-t#j$dddt'j(dt+| | || g}| D]}|j-t/|t1|j2r,t#j$ddt'j(d|Dcgc]+}|j5||j2|j6|-}}|j|||j2||||||j6|j4|xsd| | |} | s| rd}| j9||||||||y#1swYxYwcc}w#t:$r4}!tj<|!t'j(dYd}!~!yd}!~!wwxYw)zStarts an RQ worker.QUEUESrfNAME DICT_CONFIGwN)RoundRobinWorker RandomWorkerrnrandom round_robinz WARNING: z( is deprecated. Use `--dequeue-strategy z ` instead.yellowrM)rfrorpzPERROR: Dequeue Strategy can only be one of `default`, `random` or `round_robin`.TrL)errrNrKzBRQ is currently suspended, to resume job execution run "rq resume"r8) rBr4default_worker_ttl worker_ttldefault_result_ttlmaintenance_intervaljob_monitoring_intervalr5r:exception_handlers!disable_default_exception_handlerlog_job_descriptionr7)burst logging_level date_format log_formatmax_jobs max_idle_timewith_schedulerdequeue_strategy)configr getlogging dictConfigopenospath expanduserwritestrgetpidrY __qualname__warningswarnDeprecationWarningr<rSr>r?rrXr$r r4r:r5workrerror)"rCr{r|rB results_ttlrtrvrwdisable_job_desc_loggingverbosequietexception_handlerpidryrrrr0r~r}r7rrDsettings dict_configfp worker_namestrategy_alternativemsgrxhrEworkerrcs" r,rrsz7A6G6G 1 12RH  :x||Hyk:F  '8<<'D,,}-K!!+. "''$$S)3 / '2 HHS% & '))66K::+6.+Hxm+&NOcNddno c-. CH%CC ^dhmr    ZH0" ;A  % %&6q&9 : ;  -- . KK\af g HHQK     " "*"7"7:CWCWdn #   (( !,,)!*!5$; **"..19T.O$< <!) $ e M '#!')-  m ' '6 J  a  s8--I;?A(J '0JA#J ;JJ K *KK z --durationzBSeconds you want the workers to be suspended. Default is forever.)r/rHc |/|dkr*tjdtjdt |j ||r'dj |}tj|ytjdy)z/Suspends all workers, to resume run `rq resume`NrKz*Duration must be an integer greater than 1z}Suspending workers for {0} 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_suspendr4rA)rCdurationrDrs r,r"r"1sg 1  ?@  z,,h7 &x 0  3 jkr+c Xt|jtjdy)zCResumes processing of queues, that were suspended with `rq suspend`zResuming workers.N)connection_resumer4r<r=)rCrDs r,r!r!Esj++, JJ"#r+zThe name of the queue.)r/rfz --timeoutzWSpecifies the maximum runtime of the job before it is interrupted and marked as failed.z --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.z--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)r/rfrHz--retry-intervalz#Interval between retries in seconds)r/rgrHrfz --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).zOnly 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)r7r4z Enqueued z with job-id 'z'.)r r#rr r:r4 enqueue_call create_jobr SCHEDULED schedule_jobr<r=rid)rCrEtimeout result_ttlttl failure_ttl description depends_onrVat_front retry_maxretry_interval schedule_in schedule_atrr7rrrDargskwargsfunction_stringretryschedulejobs r,enqueuerMs`'y1LD&%hf=O0K E1}i0k;7H  " "5ZJLaLa " bE                                 3)  d?6KSVVTU r+z--logging-levelz-lz --job-classzDotted path to a Job classz --num-workersrKzNumber of workers to startr{c  |jrt|jni} |xs| jddg}t|||||rt t dt |}nt}| r t | } nt} | r t | } nt} |s|rd}t||j| || | }|j||y)zStarts a RQ worker poolrirfr(N)r4 num_workersr7rYr5)r{r|) rr rrrrr$rr%rr&r4start)rCr{r|r0r7rrr~r}rYr5rrDr queue_namesserializer_classpools r, worker_poolrs67A6G6G 1 12RH#Jx||Hyk'JK ZH\ 24DZ4PQ,' 5  $Y/  % ((#!  D JJU-J8r+__main__)P__doc__rlogging.configrr>rtypingrrrrr<redis.exceptionsrrqrr versionrq.cli.helpersr r r r rrrrr rq.defaultsrrrrrr rq.exceptionsrrq.jobrr rq.logutilsr rq.registryrrrq.serializersr rq.suspensionr r!rr"rrq.utilsr#r$ rq.workerr%rq.worker_poolr&rq.worker_registrationr'r(groupversion_optionr-commandoptionargumentr@rrRfloatrdintrrboolr__name__r*r+r,rs 22 ,%   3!;,&576%8) g   gtT0BC#S$DS6 gtT0IJ i$S1 $h%2K h4 lDu3hi gtT0[\ otT8NO d9PQ lD$5MN#$ORP]jB it2cd c6@ST n30FMij oC1LStu h#=> oC1CJno n30BIde  - <   + 5  *D?^_ k44FG it2DE #*GRVW gYZ 3T4Nvw ld9\] c4>uv  $;VW ndD7Z[ %9p#f$\Xw^x[XFH`  fp?vkUeFfR l!eloplql"$$  i$