>Tf"ddlZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZdd lmZdd lmZdd lmZdd lmZmZdd lmZddlmZddlmZddl m!Z!dZ"Gdde j#Z$dS)N)settings)GenericForeignKey)ValidationError)MinValueValidator)models)reverse)timezone)gettext)JobStatusChoices) ObjectType)job_end job_start) get_config)RQ_QUEUE_DEFAULT)RestrictedQuerySet)get_queue_for_model)Jobc eZdZdZejddejddZejddZ e ddd Z ej e d d Zeje ddZeje dddZeje dddedfe dZeje dddZeje dddZejejejdddZej e ddeejZeje dddZej e dd dZ!ej"e d d!Z#e$j%Z&Gd"d#Z'd$Z(d%Z)d&Z*fd'Z+e,d(Z-fd)Z.d*Z/ej0d+fd,Z1e2d/d.Z3xZ4S)0rzs Tracks the lifecycle of a job which represents a background task (e.g. the execution of a custom script). zcontenttypes.ContentTypejobsT)to related_name on_deleteblanknull)rr object_type object_idF)ct_fieldfk_fieldfor_concrete_modelname) verbose_name max_lengthcreated)r" auto_now_add scheduled)r"rrintervalz Recurrence interval (in minutes))r"rr validators help_textstarted completed+)rrrrrstatus)r"r#choicesdefaultdataerror)r"editablerzjob ID)r"uniquecdeZdZdgZejdfZedZedZ dS)Job.Metaz-created)rr)fieldsjobrN) __name__ __module__ __qualname__orderingrIndexindexes_r"verbose_name_plural5/var/www/html/netbox-4.1.3/netbox/core/models/jobs.pyMetar7lsN< FL < = = = qxx aiirCrEc*t|jSN)strjob_idselfs rD__str__z Job.__str__ts4;rCc|jjdkrtdd|jiS|jjdkrtdd|jiStd|jgS) N reportmodulezextras:report_resultjob_pk)kwargs scriptmodulezextras:script_resultzcore:job)args)rmodelrpkrJs rDget_absolute_urlzJob.get_absolute_urlwsq   !^ 3 32Hdg;NOOO O   !^ 3 32Hdg;NOOO Oz 2222rCcJtj|jSrG)r colorsgetr.rJs rDget_status_colorzJob.get_status_colors&**4;777rCct|jtjdvr5t td|jdS)Nrz5Jobs cannot be assigned to this object type ({type}).)type) supercleanrr objects with_featurerr@format)rK __class__s rDr]z Job.cleansq    :#5#B#B6#J#J J J!IJJQQW[WgQhh  K JrCc|jsdS|jp|j}|sdS|j|z }t|d\}}t |d|ddS)N<z minutes, z.2fz seconds)r,r+r$divmod total_secondsint)rK start_timedurationminutessecondss rDrhz Job.durationsx~ 4\1T\  4>J.!("8"8":":B??g,,??'?????rCcLtj|i|tj|jjt}tj |}| t|j }|r| dSdSrG)r\deleterQUEUE_MAPPINGSrXrrSr django_rq get_queue fetch_jobrHrIcancel)rKrRrP rq_queue_namequeuer9ras rDrlz Job.deletes''''" 3778H8NP`aa #M22ooc$+..//   JJLLLLL  rCc|jdStj|_tj|_|tj|dS)zQ Record the job's start time and update its status to "running." N) r+r nowr STATUS_RUNNINGr.saversendrJs rDstartz Job.startsO < # F |~~ &5   trCNcLtj}||vrCttdd|||_|r||_tj |_ | tj |dS)zc Mark the job as completed, optionally specifying a particular termination status. z:Invalid status for job termination. Choices are: {choices}z, )r0N)r TERMINAL_STATE_CHOICES ValueErrorr@r`joinr.r3r rur,rwr rx)rKr.r3valid_statusess rD terminatez Job.terminates*@  ' 'NOOVV IIn55W   DJ!   TrCc t|r|rttd|r)tj|d} |j} ndx} } t | r| jnd} tj | } |r tj n tj } tj| | || |||tj}|r|dt#|j|d|nJ|r%| j||ft#|j|d|n#| j|ft#|j|d||S)a Create a Job instance and enqueue a job using the given callable Args: func: The callable object to be enqueued for execution instance: The NetBox object to which this job pertains (optional) name: Name for the job (optional) user: The user responsible for running the job schedule_at: Schedule the job to be executed at the passed date and time interval: Recurrence interval (in minutes) immediate: Run the job immediately without scheduling it in the background. Should be used for interactive management commands only. zJenqueue() cannot be called with values for both schedule_at and immediate.F)rN)rrr r.r&r'userrI)rIr9rB)r|r@r r^ get_for_modelrTrrSrnror STATUS_SCHEDULEDSTATUS_PENDINGrcreateuuiduuid4rHrI enqueue_atenqueue)clsfuncinstancer r schedule_atr' immediaterPrrrrrsr.r9s rDrz Job.enqueues}  n9 nQkllmm m  +$,::8X]:^^K II&* *K)+,VK,=,=RVWW #M226Af!22GWGfk  #!:<<!     K D ;CJS ; ;F ; ; ; ; K E [$ Zs3:C Z ZSY Z Z Z Z EM$ Js3:C J J6 J J J rC)NrNNNF)5r:r;r<__doc__r ForeignKeyCASCADErPositiveBigIntegerFieldrrobject CharFieldr@r DateTimeFieldr$r&PositiveIntegerFieldrr'r+r,rAUTH_USER_MODELSET_NULLrr rr. JSONFieldr2 TextFieldr3 UUIDFieldrIr as_managerr^rErLrUrYr]propertyrhrlrySTATUS_COMPLETEDr classmethodr __classcell__)ras@rDrrs$&# %.  K/. I  F 6 QvYY   D#f"Qy\\G%$Q{^^ I +v*Qz]]   a  !677H#f"Qy\\ G %$Q{^^ I 6   #/     DV Qx[[  / F 6 QvYY    D F QwZZ   E V Qx[[F , +--G((((((((   333888 @ @X @    0@,111[11111rCr)%rrn django.confr"django.contrib.contenttypes.fieldsrdjango.core.exceptionsrdjango.core.validatorsr django.dbr django.urlsr django.utilsr django.utils.translationr r@ core.choicesr core.modelsr core.signalsr r netbox.configrnetbox.constantsrutilities.querysetsrutilities.rqworkerr__all__ModelrrBrCrDrsu  @@@@@@222222444444!!!!!!111111))))))""""""++++++++$$$$$$------222222222222  aaaaa&,aaaaarC