o `oi@sddlmZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl mZejddkr=eneZeeZGdddeZdS) )print_functionN) import_module)settings)Settingsc@sdeZdZddZddZddZddZd d Zd d Zd dZ ddZ ddZ ddZ ddZ dS)CrontabcKs4t|dd|_|dd|_g|_tt|_dS)N verbosityreadonlyF)intgetrr crontab_linesrr)selfoptionsr^/var/www/html/kuke-dev/django-kuke/venv/lib/python3.10/site-packages/django_crontab/crontab.py__init__szCrontab.__init__cCs ||S)zH Automatically read crontab when used as with statement )readrrrr __enter__szCrontab.__enter__cCs|js |dSdS)zc Automatically write back crontab when used as with statement if readonly is False N)r write)rtypevalue tracebackrrr__exit__%s zCrontab.__exit__cCstd|jj|_dS)z8 Reads the crontab into internal buffer z%s -lN)ospopenrCRONTAB_EXECUTABLE readlinesr rrrrr,sz Crontab.readcCsZt\}}t|d}|jD]}||q|td|jj |ft |dS)z8 Writes internal buffer back to crontab wz%s %sN) tempfilemkstemprfdopenr rclosesystemrrunlink)rfdpathtmplinerrrr2s    z Crontab.writecCs|jjD]g}t|dkrt|dtr|d}n t|dkr#|d}nd}|j|jj|d|jjd t d|jj |jj |jj dd|||jjrNd |jjnd||jjg d |jd krktd |||fqdS) zN Adds all jobs defined in CRONJOBS setting to internal buffer rr NZcrontabrunz --settings=%s)timecommentcommandr z adding cronjob: (%s) -> %s)rCRONJOBSlen isinstance string_typer appendZCRONTAB_LINE_PATTERNCRONTAB_COMMENTjoinfilterZCOMMAND_PREFIXZPYTHON_EXECUTABLEZDJANGO_MANAGE_PATH_Crontab__hash_jobZDJANGO_SETTINGS_MODULEZCOMMAND_SUFFIXrprint)rjobZ job_suffixrrradd_jobs>s0      zCrontab.add_jobsc Cstd|jddD]B}|jj|}|rM|dd|jjkrM|jdkrMtd|ddd||dd|dd dd ddfq dS) z2 Print the jobs from from crontab z!Currently active jobs in crontab:Nrr*r z%s -> %sr crontab run ) r:r rCRONTAB_LINE_REGEXPfindallr6rsplit_Crontab__get_job_by_hashfindrr)r;rrr show_jobs]s 2zCrontab.show_jobsc Cs|jddD]H}|jj|}|rO|dd|jjkrO|j||jdkrOtd|ddd| |dd|dd ddddfqdS) zS Removes all jobs defined in CRONJOBS setting from internal buffer Nrr*r zremoving cronjob: (%s) -> %srr=r>) r rr?r@r6removerr:rArBrCrDrrr remove_jobsks  2zCrontab.remove_jobsc CsD||}|d}t|dkrt|dts|dng}t|dkr&|dni}d}|jjr\ttj t d|d}|j }z t |t jt jBWnty[td|YdSw|dd\}} t|} t| | } z | |i|Wn td |Y|jjrz t |t jWdStytd |YdSwdS) zI Executes the corresponding function defined in CRONJOBS r rNzdjango_crontab_%s.lockrz3Tried to start cron job %s that is already running..z Failed to complete cronjob at %szError unlocking %s)rBr2r3r4rZ LOCK_JOBSopenrr'r7r gettempdirnamefcntlflockLOCK_EXLOCK_NBIOErrorloggerwarningrsplitrgetattr exceptionLOCK_UN) rjob_hashr;Zjob_nameZjob_argsZ job_kwargsZlock_file_name lock_file module_pathZ function_namemodulefuncrrrrun_jobzs: &     zCrontab.run_jobcCs*tjdd|}t|d}|S)z9 Builds an md5 hash representing the job T) sort_keyszutf-8)json JSONEncoderencodehashlibmd5 hexdigest)rr;jhrrrZ __hash_jobszCrontab.__hash_jobcCs0|jjD] }|||kr|Sqtd|)z- Finds the job by given hash zNo job with hash %s found. It seems the crontab is out of sync with your settings.CRONJOBS. Run "python manage.py crontab add" again to resolve this issue!)rr1r9 RuntimeError)rrXr;rrrZ__get_job_by_hashs zCrontab.__get_job_by_hashN)__name__ __module__ __qualname__rrrrrr<rErGr]r9rBrrrrrs " r) __future__rrMrbr_loggingrr sys importlibrZ django.confrZdjango_crontab.app_settingsr version_info basestringstrr4 getLoggerrhrRobjectrrrrrs