Wwg2HddlZddlZddlZddlmZmZddlmZddlm Z m Z ddl m Z ddlmZmZmZddlmZddlmZdd lmZdd lmZmZdd lmZdd lmZmZdd l m!Z!m"Z"ejFe$Z%GddZ&Gdde&eZ'Gdde&eZ(ddZ)dede*fdZ+y)N)UnionList)events)JobSubmissionEventJobExecutionEvent)Job) BaseJobStoreJobLookupErrorConflictingIdError)MemoryJobStore) BaseScheduler)db) transactionIntegrityError)util) DjangoJobDjangoJobExecution)get_apscheduler_datetimeget_django_internal_datetimeceZdZdZdZfdZedefdZede de e dffdZ ede de e dffdZ d ZxZS) DjangoResultStoreMixinzfMixin class that adds the ability for a JobStore to store job execution results in the Django databaseNct||||jjt_|j yN)superstart _scheduler _create_lockrlockregister_event_listeners)self scheduleralias __class__s S/var/www/horilla/myenv/lib/python3.12/site-packages/django_apscheduler/jobstores.pyrzDjangoResultStoreMixin.starts5  i''+oo&B&B&D# %%'eventc |jtjk(rStj|j |j |jdtj}|jS|jtjk(rgtj}d|j d}tj|j |j |jd||}|jStd|jdtjtjgd#t$r&tjd|j d Yy wxYw) a Create and return new job execution instance in the database when the job is submitted to the scheduler. :param event: JobExecutionEvent instance :return: DjangoJobExecution ID or None if the job execution could not be logged. rzExecution of job 'z7' skipped: maximum number of running instances reached! exceptionz-Don't know how to handle JobSubmissionEvent ''. Expected one of ''.Job '8' no longer exists! Skipping logging of job execution...N)coderEVENT_JOB_SUBMITTEDratomic_update_or_createrjob_idscheduled_run_timesSENTEVENT_JOB_MAX_INSTANCES MAX_INSTANCESNotImplementedErrorrloggerwarningid)clsr& job_executionstatusr)s r$handle_submission_eventz.DjangoResultStoreMixin.handle_submission_event'sM" zzV777 2 J JHHLL--a0&++ ! B5v===+99)7)* !3 J JHHLL--a0' ! $*CEJJ<P & : :FuzzlK--.b2  .FF (("** M   NN ~%]^   s AB,CCcn |jtjk(r|jr+t |j}t |j }nd|j d}d}tj|j|j |jtj||}|j&S|jtjk(rdtj}d|j d}tj|j|j |j||}|j&Std|jd tjtjtjgd #t $r&t"j%d|j d YywxYw) z Store "failed" job execution status in the database. :param event: JobExecutionEvent instance :return: DjangoJobExecution ID or None if the job execution could not be logged. r,z' raised an error!N)r) tracebackzRun time of job 'z ' was missed!r(r@r*r+r-)r.rEVENT_JOB_ERRORr)strrFr1rr0rrBERROREVENT_JOB_MISSEDMISSEDr6r4rr7r8r9)r:r&r)rFr;r<s r$handle_error_eventz)DjangoResultStoreMixin.handle_error_eventrs) zzV333?? #EOO 4I #EOO 4I"' ~5G HI $I 2 J JHHLL,,&,,'' ! B1v666+22/ ~]K 2 J JHHLL,,' ! &*B5::,O & 6 68V8VX^XoXopqqsu  NN ~%]^   s B-F;A5F+ + Z +< sDyAQ  82 '82 U39=M2 2 h r%rceZdZdZej fdeffd Zejde de de ffdZ dee fdZejd Zd Zejd e fd Zejd e fd Zejde fdZejdZdZdZejdZdZxZS)DjangoJobStorea5 Stores jobs in a Django database. Based on APScheduler's `MongoDBJobStore`. See: https://github.com/agronholm/apscheduler/blob/master/apscheduler/jobstores/mongodb.py :param int pickle_protocol: pickle protocol level to use (for serialization), defaults to the highest available pickle_protocolc0t|||_yr)r__init__rZ)r rZr#s r$r\zDjangoJobStore.__init__s .r%r1r>Nc tjj|j}|r|j |SdS#tj $rYywxYwN)r9)robjectsget job_state_reconstitute_job DoesNotExist)r r1ras r$ lookup_jobzDjangoJobStore.lookup_jobsV !))---8BBI8A4)))4 Kt K%%  ss?P?P"Q$ll3+;+;+=t?S?ST0 1 1" 1(00 1 1 1sB-A*B  B**B--B6ctj5 tjj j |j }t|j|_tj|j|j|_ |j dddy#tj$rt!|j wxYw#1swYyxYwr^)rrxrr_select_for_updater`r9rrmrzr{r|rZrasavercr )r rqdb_jobs r$ update_jobzDjangoJobStore.update_jobs   ! - -"**<<>BBcffBM'CCDUDU'V$#)<<$$&(<(<$   - -)) -$SVV,, - - -sC"BB66)CC""C+ctj5 tjj j |j  dddy#tj$r t|wxYw#1swYyxYwr^) rrxrr_rr`deletercr )r r1s r$ remove_jobzDjangoJobStore.remove_jobsx    ! - -!!33599V9DKKM - -)) -$V,, - - -sA? +  NN3N3CD E    $ $N $ ; B B D  + &&-fX5FG""6*  +s B119C-,C-cPd|jjd|jdS)N)r#rPrZrOs r$__repr__zDjangoJobStore.__repr__7s+4>>**++cfd}|S)a Helper decorator for job registration. Automatically fills id parameter to prevent jobs duplication. See this comment for explanation: https://github.com/jcass77/django-apscheduler/pull/9#issuecomment-342074372 Usage example:: @register_job(scheduler, "interval", seconds=1) def dummy_job(): print("I'm a job!") :param scheduler: Scheduler instance :param args, kwargs: Params, will be passed to scheduler.add_job method. See :func:`BaseScheduler.add_job` ctjdtjd|jd|j j |gi|S)NzThe 'register_job' decorator is deprecated since version 0.5.0. Please use APScheduler's add_job() method or @scheduled_job decorator instead.r9.)rrr setdefaultrQrPr})funcargskwargsr!s r$wrapper_register_jobz*register_job..wrapper_register_job_s\  3  $4??"31T]]O DE $000 r%r)r!rrrs``` r$ register_jobrNs"  r%r),loggingrzrtypingrr apschedulerrapscheduler.eventsrrapscheduler.jobrrapscheduler.jobstores.baser r r apscheduler.jobstores.memoryr apscheduler.schedulers.baser djangor django.dbrrdjango_apschedulerrdjango_apscheduler.modelsrrdjango_apscheduler.utilrr getLoggerrPr7rrYrrcallablerrr%r$rs D2WW751#C   8 $a a HzV+\zVz 1>   M x r%