a d*@sddlmZmZddlmZmZddlmZddlmZddl m Z ddl Z ddl mZddlmZe eZGd d d ejZGd d d ejZGd ddejZdS)) timedeltadatetime)models transaction)UniqueConstraint)timezone) gettext_lazyN)util)get_django_internal_datetimec@sTeZdZejddeddZejdddeddZe Z ddZ Gd d d Z d S) DjangoJobTzUnique id for this job.) max_length primary_key help_textzADate and time at which this job is scheduled to be executed next.)db_indexblanknullrcCs.|jrdt|jnd}|jd|dS)Nz next run at: pausedz ()) next_run_timer Zget_local_dt_formatid)selfstatusrU/var/www/html/django/DPS/env/lib/python3.9/site-packages/django_apscheduler/models.py__str__ s zDjangoJob.__str__c@seZdZdZdS)zDjangoJob.Meta)rN)__name__ __module__ __qualname__orderingrrrrMeta(sr N) rrrr CharField_r DateTimeFieldrZ BinaryFieldZ job_staterr rrrrr s  r c@seZdZedddZdS)DjangoJobExecutionManager)max_agecCs"|jtt|dddS)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)Z run_time__lteN)filterrnowrdelete)rr%rrrdelete_old_job_executions-sz3DjangoJobExecutionManager.delete_old_job_executionsN)rrrintr*rrrrr$,sr$c @seZdZdZdZdZdZdZddeeefDZe j de d d Z e j ee je d d Ze jd ee ddZe jde ddZe jdddde ddZe jdddde ddZe jdde ddZe jde ddZeZeejd$e e!e e e ddddZ"d d!Z#Gd"d#d#Z$dS)%DjangoJobExecutionzStarted executionZExecutedzMissed!zMax instances!zError!cCsg|] }||fqSrr).0xrrr >szDjangoJobExecution.Tz!Unique ID for this job execution.)rrz'The job that this execution relates to.)Z on_deleter2z)The current status of this job execution.)r choicesrz-Date and time at which this job was executed.)rrNz(Total run time of this job (in seconds).)Z max_digitsZdecimal_placesdefaultrrz)Timestamp at which this job was finished.izADetails of exception that occurred during job execution (if any).)r rrzCTraceback of exception that occurred during job execution (if any).)rr)job_idrun_timer exception tracebackreturnc Cs2|t|}tt}||}|}zt~tj j ||d} |tj kr|| WdWWdS|| _ || _ || _|r|| _|r|| _| Wdn1s0YWnBtjy |tj krd}d}tjj|||||||d} Yn0Wdn1s$0Y| S)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. )r5r6N)r5r6rdurationfinishedr7r8)r rr( total_seconds timestamprZatomicr,objectsZselect_for_updategetSENTr;r:rr7r8saveZ DoesNotExistcreate) clslockr5r6rr7r8r;r:Z job_executionrrratomic_update_or_createsD     "* , z*DjangoJobExecution.atomic_update_or_createcCs|jd|jd|jdS)Nz: job 'z' (r)rr5r)rrrrrszDjangoJobExecution.__str__c@s"eZdZdZeddgddgZdS)zDjangoJobExecution.Meta)z -run_timer5r6Zunique_job_executions)fieldsnameN)rrrrr constraintsrrrrr s r )NN)%rrrr@SUCCESSZMISSEDZ MAX_INSTANCESERRORZSTATUS_CHOICESrZ BigAutoFieldr"rZ ForeignKeyr ZCASCADEZjobr!rr#r6Z DecimalFieldr:r;r7Z TextFieldr8r$r> classmethodr Zretry_on_db_operational_errorstrrrErr rrrrr,7s Qr,)rrZ django.dbrrZdjango.db.modelsrZ django.utilsrZdjango.utils.translationrr"loggingZdjango_apschedulerr Zdjango_apscheduler.utilr getLoggerrloggerZModelr Managerr$r,rrrrs