o dV@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)selfoptionsrh/var/www/html/myvaluetrips/my_value_trip_new/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 Ncrontabrunz --settings=%s)timecommentcommandr z adding cronjob: (%s) -> %s)rCRONJOBSlen isinstance string_typer appendCRONTAB_LINE_PATTERNCRONTAB_COMMENTjoinfilterCOMMAND_PREFIXPYTHON_EXECUTABLEDJANGO_MANAGE_PATH_Crontab__hash_jobDJANGO_SETTINGS_MODULECOMMAND_SUFFIXrprint)rjob 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 ) rAr rCRONTAB_LINE_REGEXPfindallr8rsplit_Crontab__get_job_by_hashfindrr)rBrrr 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) -> %srrErF) r rrGrHr8removerrArIrJrKrLrrr 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)rJr3r4r5r LOCK_JOBSopenrr'r9r gettempdirnamefcntlflockLOCK_EXLOCK_NBIOErrorloggerwarningrsplitrgetattr exceptionLOCK_UN) rjob_hashrBjob_namejob_args job_kwargslock_file_name lock_file module_path 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)rrBjhrrr __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!)rr2r> RuntimeError)rrarBrrr__get_job_by_hashs zCrontab.__get_job_by_hashN)__name__ __module__ __qualname__rrrrrrDrMrOrkr>rJrrrrrs " r) __future__rrVrprmloggingrr sys importlibr django.confrdjango_crontab.app_settingsr version_info basestringstrr5 getLoggerrxr[objectrrrrrs