MfddlmZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl mZejddkreneZejeZGddeZdS) )print_functionN) import_module)settings)SettingscPeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d S) Crontabc t|dd|_|dd|_g|_t t |_dS)N verbosityreadonlyF)intgetr r crontab_linesrr)selfoptionss U/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/django_crontab/crontab.py__init__zCrontab.__init__sOW[[a8899 J66  ** c.||S)zH Automatically read crontab when used as with statement )readrs r __enter__zCrontab.__enter__s  rc@|js|dSdS)zc Automatically write back crontab when used as with statement if readonly is False N)r write)rtypevalue tracebacks r__exit__zCrontab.__exit__%s)}  JJLLLLL  rcvtjd|jjz|_dS)z8 Reads the crontab into internal buffer z%s -lN)ospopenrCRONTAB_EXECUTABLE readlinesrrs rrz Crontab.read,s2 Xg 0P&PQQ[[]]rc0tj\}}tj|d}|jD]}|||tj|jj d|tj |dS)z8 Writes internal buffer back to crontab w N) tempfilemkstempr!fdopenrrclosesystemrr#unlink)rfdpathtmplines rrz Crontab.write2s#%%DiC  &  D IIdOOOO  T]===ttDEEE $rc|jjD]F}t|dkr$t|dtr |d}nt|dkr |d}nd}|j|jj|d|jjd td|jj |jj |jj dd|||jjrd |jjznd||jjg d z|jd kr(t%d ||d |HdS)zN Adds all jobs defined in CRONJOBS setting to internal buffer rrr'Ncrontabrunz --settings=%s)timecommentcommandr z adding cronjob: () -> )rCRONJOBSlen isinstance string_typerappendCRONTAB_LINE_PATTERNCRONTAB_COMMENTjoinfilterCOMMAND_PREFIXPYTHON_EXECUTABLEDJANGO_MANAGE_PATH_Crontab__hash_jobDJANGO_SETTINGS_MODULECOMMAND_SUFFIXr print)rjob job_suffixs radd_jobszCrontab.add_jobs>sd=) T TC3xx!|| 3q6; ? ?| V SA V    % %dm&HA=888F4M0M3M4uOOC((NRmNrzOdm&JJJxzM0 2 % %   L L '   ~""8L8L8L8LccRSSS3 T Trc  td|jddD]}|jj|}|r|dd|jjkr|jdkrt|dddd||dd|dd dd zdddS) z2 Print the jobs from from crontab z!Currently active jobs in crontab:Nrr3r rz -> crontab run ) rJrrCRONTAB_LINE_REGEXPfindallrAr split_Crontab__get_job_by_hashfindrr1rKs r show_jobszCrontab.show_jobs]s 2333&qqq)  D-3;;DAAC s1vayDM$AAA>Q&&Aq ))!,,,..s1vayQ 9V9VY[9[9\9\/]/c/c/e/efg/hiii   rc "|jddD]}|jj|}|r|dd|jjkr|j||jdkrtd|dddd| |dd|dd dd zdddS) zS Removes all jobs defined in CRONJOBS setting from internal buffer Nrr3r zremoving cronjob: (rr:rOrP) rrrQrRrAremover rJrSrTrUrVs r remove_jobszCrontab.remove_jobsks&qqq)  D-3;;DAAC s1vayDM$AAA"))$///>Q&&EAq ))!,,,..s1vayQ 9V9VY[9[9\9\/]/c/c/e/efg/hiii   rc||}|d}t|dkr#t|dts|dng}t|dkr|dni}d}|jjrt tj tj d|zd}|j } tj|tjtjzn,#t"$rt$d|YdSwxYw|dd\}} t+|} t-| | } | |i|n"#t$d |YnxYw|jjrN tj|tjdS#t"$rt$d |YdSwxYwdS) zI Executes the corresponding function defined in CRONJOBS r rNzdjango_crontab_%s.lockr&z3Tried to start cron job %s that is already running..z Failed to complete cronjob at %szError unlocking %s)rTr<r=r>r LOCK_JOBSopenr!r/rBr( gettempdirnamefcntlflockLOCK_EXLOCK_NBIOErrorloggerwarningrsplitrgetattr exceptionLOCK_UN) rjob_hashrKjob_namejob_args job_kwargslock_file_name lock_file module_path function_namemodulefuncs rrun_jobzCrontab.run_jobzs$$X..q6 XX\\*SV[2Q2Q\3q66WY"3xx!||SVV  = " RW\\(*=*?*?AY\dAdeegjkkI&^N  Iu}u}'DEEEE   TVYZZZ &.__S!%<%<" ]{++v}-- F D( )j ) ) ) ) F   ? E E E E E = "   Iu}55555     !5~FFF   s0 ,C88%D! D!E&&FF66%GGctjd|}tj|d}|S)z9 Builds an md5 hash representing the job T) sort_keyszutf-8)json JSONEncoderencodehashlibmd5 hexdigest)rrKjhs r __hash_jobzCrontab.__hash_jobsQ  t , , , 3 3C 8 8 K)) * * 4 4 6 6rc~|jjD]}|||kr|cS td|z)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!)rr;rG RuntimeError)rrmrKs r__get_job_by_hashzCrontab.__get_job_by_hashs^=)  Cs##x// 0 NPX Y   rN)__name__ __module__ __qualname__rrrrrrMrWrZrwrGrTrrr r s+++ ^^^   TTT>         D      rr ) __future__rrbr}rzloggingr!r(sys importlibr django.confrdjango_crontab.app_settingsr version_info basestringstrr> getLoggerrrgobjectr rrrrs%%%%%%    ###### 000000,Q/144jj#  8 $ $X X X X X fX X X X X r