Wwg* ddlmZmZddlmZmZddlmZddlmZddl m Z ddl Z ddl mZddlmZe j"eZGd d ej(ZGd d ej,ZGd dej(Zy)) timedeltadatetime)models transaction)UniqueConstraint)timezone) gettext_lazyN)util)get_django_internal_datetimeceZdZejddedZejdddedZejZ dZ Gdd Z y ) DjangoJobTzUnique id for this job.) max_length primary_key help_textzADate and time at which this job is scheduled to be executed next.)db_indexblanknullrc|jr"dtj|jnd}|jd|dS)Nz next run at: pausedz ()) next_run_timer get_local_dt_formatid)selfstatuss P/var/www/horilla/myenv/lib/python3.12/site-packages/django_apscheduler/models.py__str__zDjangoJob.__str__ sL!!D44T5G5GHI J  ''"VHA&&ceZdZdZy)DjangoJob.Meta)rN)__name__ __module__ __qualname__orderingrrMetar!(s%rr'N) r"r#r$r CharField_r DateTimeFieldr BinaryField job_staterr'r&rrr r sj   DA6O4P B)F((  O M#""$I'&&rr ceZdZdefdZy)DjangoJobExecutionManagermax_agec|jtjt|z j y)z Delete old job executions from the database. :param max_age: The maximum age (in seconds). Executions that are older than this will be deleted. )seconds) run_time__lteN)filterrnowrdelete)rr/s rdelete_old_job_executionsz3DjangoJobExecutionManager.delete_old_job_executions-s+ (,,.9W3M"M NUUWrN)r"r#r$intr6r&rrr.r.,sXXrr.ceZdZdZdZdZdZdZeeefDcgc]}||fc}}Ze jde dZ e jee je d  Ze j"d ee d  Ze j&de dZe j*dddde dZe j*dddde dZe j"dde dZe j2de dZeZeej> d%de de!de de de d df d!Z"d"Z#Gd#d$Z$ycc}}w)&DjangoJobExecutionzStarted executionExecutedzMissed!zMax instances!zError!Tz!Unique ID for this job execution.)rrz'The job that this execution relates to.) on_deleter2z)The current status of this job execution.)rchoicesrz-Date and time at which this job was executed.)rrNz(Total run time of this job (in seconds).) max_digitsdecimal_placesdefaultrrz)Timestamp at which this job was finished.izADetails of exception that occurred during job execution (if any).)rrrzCTraceback of exception that occurred during job execution (if any).)rrjob_idrun_timer exception tracebackreturnc |5t|}ttj}||z j}|j } t j 5tjjj||} |tjk(r| cdddcdddS|| _ || _ || _|r|| _|r|| _| j#dddddd S#1swYxYw#tj$$r@|tjk(rd}d}tjj'|||||||} YhwxYw#1swY SxYw)a Uses an APScheduler lock to ensure that only one database entry can be created / updated at a time. This keeps django_apscheduler in sync with APScheduler and maintains a 1:1 mapping between APScheduler events that are triggered and the corresponding DjangoJobExecution model instances that are persisted to the database. :param lock: The lock to use when updating the database - probably obtained by calling _scheduler._create_lock() :param job_id: The ID to the APScheduler job that this job execution is for. :param run_time: The scheduler runtime for this job execution. :param status: The new status for ths job execution. :param exception: Details of any exceptions that need to be logged. :param traceback: Traceback of any exceptions that occurred while executing the job. :return: The ID of the newly created or updated DjangoJobExecution. )rCrDN)rCrDrdurationfinishedrErF)r rr4 total_seconds timestampratomicr9objectsselect_for_updategetSENTrJrIrrErFsave DoesNotExistcreate) clslockrCrDrrErFrJrI job_executions ratomic_update_or_createz*DjangoJobExecution.atomic_update_or_creates|64 3H=H3HLLNCH 8+::$>$P$P$R$V$V%%W%M!3!8!88 -))4 4 2.6M*-5M*+1M( 2; / 2; /!&&(5)4 l[))8&22 /444#H#H 2 : : A A!%!%%''!B!  K4 lsPA E&D$AD( D;7D2DD DAE# E&"E##E&&E0cT|jd|jd|jdS)Nz: job 'z' (r)rrCr)rs rrzDjangoJobExecution.__str__s''''$++c$++a@@rc*eZdZdZeddgdgZy)DjangoJobExecution.Meta)z -run_timerCrDunique_job_executions)fieldsnameN)r"r#r$r%r constraintsr&rrr'r[s!!  *-4K  rr')NN)%r"r#r$rQSUCCESSMISSED MAX_INSTANCESERRORSTATUS_CHOICESr BigAutoFieldr)r ForeignKeyr CASCADEjobr(rr*rD DecimalFieldrIrJrE TextFieldrFr.rN classmethodr retry_on_db_operational_errorstrrrXrr').0xs00rr9r97s DG F$M E      AN   A&I$J B &  ..=> C V  ?@ F$v##CDH#v"" >? H#v"" ?@ H!    O I!   Q I()G ''OO O  O  OO O(ObA  ss Er9)rr django.dbrrdjango.db.modelsr django.utilsrdjango.utils.translationr r)loggingdjango_apschedulerr django_apscheduler.utilr getLoggerr"loggerModelr Managerr.r9r&rrr{sc()-!6#@   8 $& &8XXf f r