o fi @szdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl mZddlm Z mZmZmZddlmZddlmZdZd Zed Zed Zd Zgd ZgdZdddddddddZddgZddddddddddddd dd!ed"d#dd$ed"gZ e!d%kZ"ej#d&kZ$e" oe%dd'vZ&e" oe%dd'vpe%d(d)vZ&d*Z'e(d+Z)ed+pd,Z*ej+,d-d.Z-d/d0Z.e"sddl/Z/d1d2Z.d3d4Z0Gd5d6d6Z1Gd7d8d8Z2Gd9d:d:Z3Gd;d<d<Z4Gd=d>d>e5Z6Gd?d@d@e7Z8GdAdBdBZ9GdCdDdDZ:dEdFZ;GdGdHdHZGdNdOdOZ?GdPdQdQeZ@dS)Ta from crontab import CronTab import sys # Create a new non-installed crontab cron = CronTab(tab='') job = cron.new(command='/usr/bin/echo') job.minute.during(5,50).every(5) job.hour.every(4) job.dow.on('SUN') job.month.during('APR', 'JUN') job.month.also.during('OCT', 'DEC') job.every(2).days() job.setall(1, 12, None, None, None) job2 = cron.new(command='/foo/bar', comment='SomeID') job2.every_reboot() jobs = list(cron.find_command('bar')) job3 = jobs[0] job3.clear() job3.minute.every(1) sys.stdout.write(str(cron.render())) job3.enable(False) for job4 in cron.find_command('echo'): sys.stdout.write(job4) for job5 in cron.find_comment('SomeID'): sys.stdout.write(job5) for job6 in cron: sys.stdout.write(job6) for job7 in cron: job7.every(3).hours() sys.stdout.write(job7) job7.every().dow() cron.remove_all(command='/foo/bar') cron.remove_all(comment='This command') cron.remove_all(time='* * * * *') cron.remove_all() output = cron.render() cron.write() cron.write(filename='/tmp/output.txt') #cron.write_to_user(user=True) #cron.write_to_user(user='root') # Croniter Extentions allow you to ask for the scheduled job times, make # sure you have croniter installed, it's not a hard dependancy. job3.schedule().get_next() job3.schedule().get_prev() N) monthrange)sleep)timedatedatetime timedelta) OrderedDict)whichzpython-crontabz3.2.0za^\s*([^@#\s]+)\s+([^@#\s]+)\s+([^@#\s]+)\s+([^@#\s]+)\s+([^@#\s]+)\s+([^\n]*?)(\s+#\s*([^\n]*)|$)z(^\s*@(\w+)\s([^#\n]*)(\s+#\s*([^\n]*)|$)z>/dev/null 2>&1)sunmontuewedthufrisatr ) Njanfebmaraprmayjunjulaugsepoctnovdec@rebootz 0 * * * *z 0 0 * * *z 0 0 * * 0z 0 0 1 * *z 0 0 1 1 *)reboothourlydailyweeklymonthlyyearlyannuallymidnightr%r$;Minutes)maxminnameHoursz Day of Month Month)r(r)r*enumz Day of WeekWindowsposix)SunOSAIXzHP-UX)mipsFcrontabz/usr/bin/crontabSHELLz/bin/shcCsdSNr<r<r<:/var/www/html/venv/lib/python3.10/site-packages/crontab.pysr>cCsttdS)z(Returns the username of the current userr)pwdgetpwuidosgetuidr<r<r<r= current_userrCcCst|tr |dS|S)z9Convert to the best string format for this python versionutf-8) isinstancebytesdecodetextr<r<r=_strs  rKc@sHeZdZdZddZddZddZdd Zd d Zd d Z ddZ dS)ProcesszRuns a program and orders the arguments for compatability. a. keyword args are flags and always appear /before/ arguments for bsd cOsttj||dtd}|dd|_|D])\}}t|dkr6|d|f7}|dur5|t|f7}q|d|d|f7}qtdd |t|D|_ d |_ d|_ d|_ d|_ dS) Nr4)r4envr.-z--=css|]}|r|VqdSr;r<).0argr<r<r= sz#Process.__init__..F)tupleshlexsplitpopPOSIXrMitemslenstrargshas_runstdoutstderr returncode)selfcmdr[flagscmd_argskeyvaluer<r<r=__init__s  zProcess.__init__cCstj|jtjtj|jdS)z4Run this process and return the popen process object)r]r^rM)spPopenr[PIPErMr`r<r<r=_runsz Process._runcCs8|}|\}}|j|_|d|_|d|_|S)z/Run this process and store whatever is returnedrE)rk communicater_rHr]r^)r`processouterrr<r<r=runs    z Process.runcC |jSr;)r]striprjr<r<r=__str__ zProcess.__str__cCsd|jdS)NzProcess())r[rjr<r<r=__repr__zProcess.__repr__cC|jSr;)r_rjr<r<r=__int__zProcess.__int__cCs t||kSr;rZr`otherr<r<r=__eq__ zProcess.__eq__N) __name__ __module__ __qualname____doc__rfrkrprsrvryr~r<r<r<r=rLs  rLcseZdZdZd@ddZddZddZed d Zed d Z ed dZ fddZ dAddZ dBddZ dCddZdDddZddZdEd d!ZdFd"d#ZdGd$d%Zd&d'Zd(d)Zd*d+Zed,d-Zed.d/Zd0d1Zd2d3Zd4d5Zd6d7Zd8d9Zd:d;Zdd?Z Z!S)HCronTaban Crontab object which can access any time based cron using the standard. user - Set the user of the crontab (default: None) * 'user' = Load from $username's crontab (instead of tab or tabfile) * None = Don't load anything from any user crontab. * True = Load from current $USER's crontab (unix only) * False = This is a system crontab, each command has a username tab - Use a string variable as the crontab instead of installed crontab tabfile - Use a file for the crontab instead of installed crontab log - Filename for logfile instead of /var/log/syslog NcCs`d|_d|_d|_t|_d|_t|_t ot dk|_ ||_ ||_ ||_||||_dS)Nr)linescronsfilen CRON_COMMAND cron_commandrMr _parked_envWINOSrArBroot_userintabtabfileread_log)r`usertabrlogr<r<r=rfs  zCronTab.__init__cCs|Sr;r<rjr<r<r= __enter__szCronTab.__enter__cCs |dSr;write)r`exc_typeexc_valexc_tbr<r<r=__exit__rzCronTab.__exit__cCs>ddlm}|jdust|jtr||j|jpdd|_|jS)z?Returns the CronLog object for this tab (user or root tab only)r)CronLogNrr)cronlogrrrFrZr)r`rr<r<r=rs z CronTab.logcCs|jdurtS|jS)z4Return user's username of this crontab if applicableTrrCrjr<r<r=rs z CronTab.usercCs*|jr|jdur|jtkrd|jiSiS)z3Returns the user option for the crontab commandlineTurrjr<r<r=user_opts  zCronTab.user_optcsZ|dkr|r|D]}|jtj||d|ddqdS|dkr$|r$tdt||dS)z&Catch setting crons and lines directlyr)cronT)rrz(You can NOT set crons attribute directlyN)appendCronItem from_lineAttributeErrorsuper __setattr__)r`r*reline __class__r<r=rs  zCronTab.__setattr__cCsg|_g|_t|_g}|jdur|jd}n`|r:||_tj|ddd }| }Wdn1s4wYn>|j rxzt |j fddi|j }Wnty]td|j d w|jrrd |jvrrtd |j d |j|jd}||_dS) z Read in the crontab from the system into the object, called automatically when listing or using the object. use for refresh. N rrE)encodinglz(Can't read crontab; No crontab program ''zno crontab forz Read crontab : )rrOrderedVariableListrMrrUrcodecsopen readlinesrrLrrrpFileNotFoundErrorIOErrorr^r])r`filenamerfhlrmr<r<r=r"s,      z CronTab.readrFc Cst|j}t|j}t|tttfr||}z t|tt t j fr'|^}}|dur7|j |}|j |}Wnt yI}zt d|d}~ww|r|j|jt|_|r~|js~|jr~|jdr~|jdddkr~||jddd|j|||j||dSd|vrd |vs| d| d kr|dd\} } | } d D]} | d| kr| d| kr| | } nq| |j| <dSdS|js|jr|j|jt|_|j|d d dS) a"Append a CronItem object to this CronTab Keyword arguments: item - The CronItem object to append line - The textual line which this item is. read - Internal use only before - Append before this CronItem, comment regex or generator Nz1Can not find CronItem in crontab to insert beforer#r.TrO z"'rr)rYrrrFrZtypeITEMREX find_commentlistrStypes GeneratorTypeindex ValueErroris_validrMupdaterrcomment set_commentrVrrinsertrUrreplace) r`itemrrbeforecron_idline_id_ror*requotr<r<r=r?sP        zCronTab.appendc CsJ|r||_n |durd|_d|_||_|jdur"||_|js"dS|jr,t|jd}n t\}}t|d}| |j|d d| |js|j sWt |tdzt|j|fi|j}Wntyvtd|jdw|}|dkr|j} td |jd |d | |j |j t |dSdS) z5Write the crontab to it's source or a given filename.Nwb)errorsrEz)Please specify user or filename to write.z)Can't write crontab, no crontab program 'rrzProgram Error: z returned r)rrrrenderrtempfilemkstemprAfdopenrencodecloserunlinkrrLrrrkrwaitr^rr]) r`rrrfilehfiledpathprocretmsgr<r<r=rqsB         z CronTab.writeTcCs |j|dS)z8Write the crontab to a user (or root) instead of a file.rr)r`rr<r<r= write_to_user zCronTab.write_to_usercks.|D]}|jdi|}|dvr|VqdS)z7Run all commands in this crontab if pending (generator))NrNr<) run_pending)r`kwargsjobrr<r<r=rszCronTab.run_pendingr<ccsdd}||kr0t}|r|t|dd7}|j|dD]}|Vqt||d7}||ksdSdS)z4Run the CronTab as an internal scheduler (generator)rr)seconds)nowr.N)rrrrr)r`timeoutcadencewarpcountrrer<r<r= run_schedulerszCronTab.run_schedulercCsg}|jD]F}t|ttfr2|ds|s!||q|s+|d|qtd|t|trK|s@|s@d|_ ||j |dqt|j d |}|rb|ddvrb|d7}|S) aRender this crontab as it would be in the crontab. errors - Should we not comment out invalid entries and cause errors? specials - Turn known times into keywords such as "@daily" True - (default) force all values to be converted (unless SYSTEMV) False - force all values back from being a keyword None - don't change the special keyword use rz# DISABLED LINE # zInvalid line: Fspecialsrr)r ) rrFrZrr startswithrrrrenabledrrMjoin)r`rrrrresultr<r<r=rs"   zCronTab.rendercCs>|s |jdur tdt||||d}||_|j||d|S)a Create a new CronItem and append it to the cron. Keyword arguments: command - The command that will be run. comment - The comment that should be associated with this command. user - For system cron tabs, the user this command should run as. pre_comment - If true the comment will apear just before the command line. before - Append this command before this item instead of at the end. Returns the new CronItem object. Fz%User is required for system crontabs.)r pre_comment)r)rrrrr)r`commandrrrrrr<r<r=news  z CronTab.newccsHt|jD]}t|ttr||jr|Vq||jvr!|VqdS)z8Return an iter of jobs matching any part of the command.N)rrrFrrfindallr)r`rrr<r<r= find_command  zCronTab.find_commandccsHt|jD]}t|ttr||jr|Vq||jkr!|VqdS)zReturn a generator of all unqiue commands used in this crontabN)rrrr`returnedrr<r<r=commandss   zCronTab.commandsccs:g}|jD]}|jr|j|vr|jV||jqdS)zAReturn a generator of all unique comments/Id used in this crontabN)rrrrr<r<r=commentss  zCronTab.commentscOst|rtdd|vr|j||dSd|vr"|j||dSd|vr0|j||dS|j|jddS)a+Removes all crons using the stated command OR that have the stated comment OR removes everything if no arguments specified. command - Remove all with this command comment - Remove all with this comment or ID time - Remove all with this time code z&Invalid use: remove_all(command='cmd')rrrN)rremoverrrr)r`r[rr<r<r= remove_allszCronTab.remove_allcGs^d}|D](}t|tttjfr|D] }|||7}qqt|tr)|||7}qtd|S)z(Remove a selected cron from the crontab.rzZYou may only remove CronItem objects, please use remove_all() to specify by name, id, etc.)rFrrSrr_remover TypeError)r`rXrrsubitemr<r<r=r"s zCronTab.removecCs|j|j|ddD]&}t|tr'|j}|j|_|j|||j_n |dkr-n|j|q |j||j|dS)zInternal removal of an itemr.Nr) rrrFrrMrrrr)r`rsiblingrMr<r<r=r0s    zCronTab._removecCs\|jdurdnd}|jrd|d|jdS|jr|jsdS|jr(d|jdSd |d S) NFzSystem rz z)rrrr)r`kindr<r<r=rvBs  zCronTab.__repr__ccs t|jD]}|VqdS)z3Return generator so we can track jobs after removalN)rr__iter__)r`rr<r<r=r LszCronTab.__iter__cC |j|Sr;)r)r`ir<r<r= __getitem__QrtzCronTab.__getitem__cC t|jSr;)rYrrjr<r<r=__len__TrtzCronTab.__len__cC|Sr;rrjr<r<r=rsWzCronTab.__str__NNNNr;)rFN)NNFT)rrF)FT)rrNFN)"rrrrrfrrpropertyrrrrrrrrrrrrrrrrrrrrrvr rrrs __classcell__r<r<rr=rsF      2 +       rc@seZdZdZdbddZddZd d Zedcd d Zd dZ ddddZ ddddZ ddZ deddZ dfddZddZddZdfddZd d!Zdgd#d$Zd%d&Zd'd(Zdhd)d*Zdid+d,Zdjd-d.Zdcd/d0Zdhd1d2Zdhd3d*Zdhd4d5Zd6d7Zd8d9Zdhd:d;Zdd?Z d@dAZ!e"dBdCZ#e"dDdEZ$e"dFdGZ%e"dHdIZ&e"dJdKZ'e"dLdMZ(e"dNdOZ)e"dPdQZ*e"dRdSZ+e"dTdUZ,dVdWZ-dXdYZ.dZd[Z/d\d]Z0d^d_Z1d`daZ2dS)krzq An item which objectifies a single line of a crontab and May be considered to be a cron job object. rNFcCs~d|_||_d|_d|_d|_d|_d|_d|_t|d|_ d|_ d|_ d|_ d|_ t|_||||r=||dSdS)NFT)r)rrvalidrspecialrrlast_runrrMrmarkerstdinrrrr set_command)r`rrrrr<r<r=rf`s$  zCronItem.__init__cCst|j|j|j|j|jfSr;)hashrrhourminutedowrjr<r<r=__hash__yszCronItem.__hash__cCst|tsdS||kS)NF)rFrr#r|r<r<r=r~|s zCronItem.__eq__cCs"||d}||_|||S)zDGenerate CronItem from a cron-line and parse out command and commentr)rparserr)clsrrrobjr<r<r=rs zCronItem.from_linecCs|jstd|j|dS)z/Delete this item and remove it from it's parentzCron item is not in a crontab!N)rUnboundLocalErrorrrjr<r<r=deleteszCronItem.deletecCsJ|r|dddd}d|vr|dd\}|_t||_d|_dS)z$Set the command and filter as needed%rz\ r.TN)rrUrrKrrrr)r`ra parse_stdinr<r<r=rs  zCronItem.set_commandcCs>|r|dddkrd|_|dd}d}||_||_dS)zSet the comment and don't filter, pre_comment indicates comment appears before the cron, otherwise it appears ont he same line after the command. NzAnsible:AnsibleT)rlstriprr)r`cmtrr<r<r=rs  zCronItem.set_commentcCsXt|}|r |ddkrd|_|d}|t|||t||dS)z:Parse a cron line string and save the info as the objects.rrFN)rKrrrr- _set_parserrSPECREX)r`rr<r<r=r$s zCronItem.parsec Cs$|sdS|dd|_|jjdurT|dddd}||ddt|dkr/|d|_n/|jr5tjntj }d|_ d|_t |t d |jdurKd n|jjpPd |n ||dddz|j|dddWdSttfy}z|jrt t |d|_ d|_WYd}~dSd}~ww) z*Set all the parsed variables into the itemNrrFr.Tz-Missing user or command in system cron %s: %sr)rrrrUrrYrloggingERRORDEBUGrLOGrrZrsetallrKeyErrorerror)r`rrrlevelror<r<r=r/s4   zCronItem._set_parseTcCs|dvr||_|jS)z&Set if this cron job is enabled or not)TFr)r`rr<r<r=enableszCronItem.enablecCrx)z6Return true if this job is enabled (not commented out)r;rjr<r<r= is_enabledzCronItem.is_enabledcCrx)z Return true if this job is valid)rrjr<r<r=rr>zCronItem.is_validcCs|s |jr tdt|jdd}d}|jr+|jjdur+|js&td|jd}|jj |d}|d||}|j rI|d |j d d7}|jsPd |}|j rt|j }|_ |j rhd |j d |}nd |}t st|jst|j r{|d |}n|d|7}t|j|S)z$Render this set cron-job to a stringz8Refusing to render invalid crontab. Disable to continue.r)z\%rFz'Job to system-cron format, no user set!rrz %rz# rr)rrrrKrrrrrrrrrSYSTEMVrrZrM)r`rrrrendrrr<r<r=rs.  zCronItem.rendercCs||jdS)z6Set to every reboot instead of a time pattern: @rebootr)clearrr7rjr<r<r= every_reboots zCronItem.every_rebootr.cCs t|j|S)af Replace existing time pattern with a single unit, setting all lower units to first value in valid range. For instance job.every(3).days() will be `0 0 */3 * *` while job.day().every(3) would be `* * */3 * *` Many of these patterns exist as special tokens on Linux, such as `@midnight` and `@hourly` )Everyr)r`unitr<r<r=everys zCronItem.everycGs |jj|S)zReplace existing time pattern with these five values given as args: job.setall("1 2 * * *") job.setall(1, 2) == '1 2 * * *' job.setall(0, 0, None, '>', 'SUN') == '0 0 * 12 SUN' )rr7r`r[r<r<r=r7 s zCronItem.setallcCrq) Clear the special and set values)rrArjr<r<r=rA zCronItem.clearcC|jj|dSznReturns the number of times this item will execute in a given year (defaults to this year) year)r frequencyr`rLr<r<r=rMzCronItem.frequencycCs|jj||||dS)znReturns the number of times this item will execute in a given hour (defaults to this hour) )rLmonthdayr )rfrequency_at_hour)r`rLrPrQr r<r<r=rRszCronItem.frequency_at_hourcCs|jj|||dS)ziReturns the number of times this item will execute in a given day (defaults to today) )rLrPrQ)rfrequency_at_day)r`rLrPrQr<r<r=rS$szCronItem.frequency_at_daycCs|jj||dS)zpReturns the number of times this item will execute in a given month (defaults to this month) )rLrP)rfrequency_at_month)r`rLrPr<r<r=rT*szCronItem.frequency_at_monthcCrIrJ)rfrequency_at_yearrNr<r<r=rU0rOzCronItem.frequency_at_yearcC|j|d|Sz1Return frequence per year times frequency per dayrKfrequency_per_yearfrequency_per_dayrNr<r<r=rM6cCrI)zlReturns the number of /days/ this item will execute on in a year (defaults to this year) rK)rrYrNr<r<r=rY:rOzCronItem.frequency_per_yearcCrq)zReturns the number of times this item will execute in any hour)rfrequency_per_hourrjr<r<r=r]DrHzCronItem.frequency_per_hourcCsN|pt}|r%|jdur||_||j}||kr%||_|SdS)zRuns the command if scheduledNr)rrr=rscheduleget_nextrp)r`r next_timer<r<r=rHs  zCronItem.run_pendingcCsTtj}||j|jdt}t|d|j |d }|j r(t |j |S)z Runs the given command as a piper:z-c)rM)rAenvironcopyrrMallgetr:rLrrpr^r6r9)r`rMshellrmr<r<r=rpUs  z CronItem.runc CsT|st}zddlm}Wnty}ztd|d}~ww||j|tdS)z(Return a croniter schedule if available.r)croniterz]Croniter not available. Please install croniter python module via pip or your package managerN)ret_type)rrcroniter.croniterrf ImportErrorr clean_render)r` date_fromrfror<r<r=r^_szCronItem.schedulec KsRzddlm}Wnty}ztd|d}~ww||jfi|}|S)z Returns a description of the crontab's schedule (if available) **kw - Keyword arguments to pass to cron_descriptor (see docs) r)ExpressionDescriptorzjcron_descriptor not available. Please installcron_descriptor python module via pip or your package managerN)cron_descriptorrlrirrjget_description)r`kwrlroexdescr<r<r= descriptionkszCronItem.descriptioncCs$|js|jr|jj|j|_|jS)z,Return a cron log specific for this job only)rrr for_programrrjr<r<r=rzs z CronItem.logcC |jdS)zReturn the minute slicerrrjr<r<r=r! zCronItem.minutecCrx)zSame as minute)r!rjr<r<r=minuteszCronItem.minutescCrs)zReturn the hour slicer.rtrjr<r<r=r ruz CronItem.hourcCrx)z Same as hour)r rjr<r<r=hoursrwzCronItem.hourscCrx)zReturn the day slice)domrjr<r<r=rQrwz CronItem.daycCrs)z!Return the day-of-the month slicer2rtrjr<r<r=ryruz CronItem.domcCrs)zReturn the month slicertrjr<r<r=rPruzCronItem.monthcCrx)z Same as month)rPrjr<r<r=monthsrwzCronItem.monthscCrs)z Return the day of the week slicer7rtrjr<r<r=r"ruz CronItem.dowcC d|dS)Nz .innercallr<)r`rrr<rr=rszEvery.set_attrcCs,|jdkrtd|jd|jddS)zSpecial every year targetr.zInvalid value 'z', outside 1 yearz@yearlyN)rDrrr7rjr<r<r=rLs z Every.yearN)rrrrrfrrLr<r<r<r=rCs  rCcseZdZdZfddZddZeddZdd Ze d d Z e d d Z ddZ d*ddZ ddZd+ddZd+ddZddZddZd+ddZd,d d!Zd-d"d#Zd.d$d%Zd&d'Zd(d)ZZS)/rzControls a list of five time 'slices' which reprisent: minute frequency, hour frequency, day of month frequency, month requency and finally day of the week frequency. cs2tddtDd|_|j||j|_dS)NcSg|]}t|qSr<) CronSlice)rPinfor<r<r= z'CronSlices.__init__..)rrfS_INFOrr7 is_self_validrrFrr<r=rfs  zCronSlices.__init__cGstj|p|fS)zObject version of is_valid)rrrFr<r<r=rzCronSlices.is_self_validc Gs(zt||WSttfyYdSw)z4Returns true if the arguments are valid cron patternF)boolrr8)r%r[r<r<r=rs zCronSlices.is_validcGsr|t|dkr||d\}|_|ddkrdSt|t|kr(tdt||D] \}}||q-dS)z.)rrjr<r<r=rj&r[zCronSlices.clean_renderTcCsz|}|jr|dur|jdkst|jd|kr|jSts;|dur;tD]\}}||kr:|tvr:d|Sq'|S)zAReturn just the first part of a cron job (the numbers or special)FrrT)rjrrrrr?rXSPECIAL_IGNORE)r`rrr*rer<r<r=r*s  zCronSlices.rendercCsd|_|D]}|qdS)rGN)rrA)r`rr<r<r=rA7s zCronSlices.clearNcCrVrWrXrNr<r<r=rM=r[zCronSlices.frequencyc Csxd}|s tj}t|d}|dD]&}|dD]}zt|||dd|vr.|d7}Wqty8Yqwq|S)zdReturns the number of times this item will execute in a given year (default is this year)rr7rzr2r.)rtodayrLrrr)r`rLrweekdaysrPrQr<r<r=rYAs     zCronSlices.frequency_per_yearcCst|dt|dS)z=Returns the number of times this item will execute in any dayrr.rYrjr<r<r=rZSszCronSlices.frequency_per_daycCs t|dS)r\rrrjr<r<r=r]WrzCronSlices.frequency_per_hourcCs6|stj}d}tddD] }||||7}q|S)zeReturns the number of /days/ this item will execute in a given year (default is this year)rr. )rrrLrrT)r`rLtotalrPr<r<r=rU[s  zCronSlices.frequency_at_yearcCs|dur|durtj}tj}n|dus|dur%td|d|d}||dvrGt||d}td|dD] }|||||7}q;|S)zkReturns the number of times this item will execute in given month (default: current month) N&One of more arguments undefined: year=, month=rrzr.)rrrLrPrrrrS)r`rLrPrdaysrQr<r<r=rTfs   zCronSlices.frequency_at_monthcCsdd|||fD}t|rt|dt|dSt|r+td|d|d|d}||dvrDtd D] }||||||7}q7|S) zhReturns the number of times this item will execute in a day (default: any executed day) cSg|]}|duqSr;r<rPxr<r<r=r~rz/CronSlices.frequency_at_day..rr.rr, day=r2)rcrYanyrrrR)r`rLrPrQ test_nonerr r<r<r=rSys  zCronSlices.frequency_at_dayc Csdd||||fD}t|rt|dSt|r)td|d|d|d|d}t|||}||dvrU||d vrU||d vrU|dd |d vrUt|d}|S) zjReturns the number of times this item will execute in a hour (default: any executed hour) cSrr;r<rr<r<r=rrz0CronSlices.frequency_at_hour..rrrrz, hour=r.r2rzrr7)rcrYrrrr)r`rLrPrQr rrrr<r<r=rRs     zCronSlices.frequency_at_hourcCrr;rrjr<r<r=rsrzCronSlices.__str__cCs|t|kSr;)rr)r`rQr<r<r=r~rzCronSlices.__eq__rr;rrr)rrrrrfrrrr7 staticmethodrrrjrrArMrYrZr]rUrTrSrRrsr~rr<r<rr=rs0          rc@seZdZdZdS) SundayErrorz&Sunday was specified as 7 instead of 0N)rrrrr<r<r<r=rsrc@s0eZdZdZddZddZddZdd Zd S) Alsoz;Link range values together (appending instead of replacing)cCs ||_dSr;)r&)r`r&r<r<r=rfrtz Also.__init__cG|jj|ddiS)zAlso every one of thesealsoT)r&rEr`ar<r<r=rErDz Also.everycGr)z Also on theserT)r&rrr<r<r=rrDzAlso.oncGr)zAlso during theserT)r&duringrr<r<r=rrDz Also.duringN)rrrrrfrErrr<r<r<r=rs  rc@seZdZdZd&ddZddZddZd'd d Zd d ZddZ ddZ d'ddZ ddZ d'ddZ eddZddZddZddZd d!Zd&d"d#Zd&d$d%ZdS)(rz,Cron slice object which shows a time patternNcCsft|tr t|}|dd|_|dd|_|dd|_|dd|_g|_|r1| |dSdS)Nr)r(r*r1) rFintrrdr)r(r*r1partsr$)r`rrer<r<r=rfs zCronSlice.__init__cCr}r;)rrZrjr<r<r=r#rzCronSlice.__hash__cCs|||dur:t|dD],}|ddks#|ddks#|dkr.|j||7_q|j|j|ddqdSdS)zSet values into the slice.N,/rrNrsunday)rArZrUfindr get_ranger parse_value)r`repartr<r<r=r$s$zCronSlice.parseFcCs|jsdSt|jd|S)z{Return the slice rendered as a crontab. resolve - return integer values instead of enums (default False) rr)r_render_values)r`resolver<r<r=rszCronSlice.rendercCr|)Nz |dds ||D]}|j|j|ddf7_q |jS)z0Set the time values to the specified placements.rFrr)rdrArr)r`roptsrr<r<r=rs z CronSlice.oncCs:|s||j|t|dt|7_|jdS)z(Set the During value, which sets a rangerNr)rArrrZ)r`vfromvtorr<r<r=rs$ zCronSlice.duringcCt|S)z+Appends rather than replaces the new values)rrjr<r<r=rszCronSlice.alsocCs g|_dS)z#clear the slice ready for new vauesN)rrjr<r<r=rA rHzCronSlice.clearcGs*t|g|R}|jdur|j|gS|gS)z"Return a cron range for this sliceN) CronRangedangling)r`vrangerr<r<r=rs  zCronSlice.get_rangeccsdi}|js |d|jD]}t|tr!|D]}d||<qqd|t|<q|D]}|Vq*dS)z(Return the entire element as an iterabler.N)rrErFrrr)r`rrbitvalr<r<r=r s     zCronSlice.__iter__cCstt|S)zr z Unrecognised z: 'rNzNo enumeration for r)r(r) get_cronvaluer1rr*r8r)r`rrrnror<r<r=r)szCronSlice.parse_valuec Csp|jdkrt|dkr|dur|Stdt||jks#t||jkr6td|d|jd|jd|j|S) z-Test the value is within range for this slicer2rNz"Detected Sunday as 7 instead of 0!rz ', not in rNz for )r(rrr)rr*)r`rerr<r<r=r7s&zCronSlice.test_valuer;r)rrrrrfr#r$rrvr~rsrErrrrrArr rrrr<r<r<r=rs(        rcCs@t|tr|St|rtt|S|stdtt||S)z=Returns a value as int (pass-through) or a special enum valuezNo enumeration allowed)rFrrZisdigitr8 CronValue)reenumsr<r<r=rCs   rc@s8eZdZdZddZddZddZdd Zd d Zd S) rz*Represent a special value in the cron linecCs||_|||_dSr;)rJrrre)r`rerr<r<r=rfPszCronValue.__init__cCs|jt|kSr;)rerrr<r<r=rTrwzCronValue.__lt__cCrr;r{rjr<r<r=rvWrzCronValue.__repr__cCrxr;rIrjr<r<r=rsZrzzCronValue.__str__cCrxr;)rerjr<r<r=ry]rzzCronValue.__int__N) rrrrrfrrvrsryr<r<r<r=rNs rrcs,t|dkr ||fdd|DS)z7Returns a rendered list, sorted and optionally resolvedr.csg|]}t|qSr<)_renderrPrrr<r=resz"_render_values..)rYsortr)valuesrrr<rr=ras rcCs:t|tr ||S|rtt|Sttr|dS|S)zReturn a single value rendered02d)rFrrrZrZERO_PAD)rerr<r<r=rhs   rc@sbeZdZdZddZddZddZdd d Zd d Zd dZ ddZ ddZ ddZ ddZ dS)rz7A range between one value and another for a time range.cGsd|_||_d|_d|_|s|dSt|dtr$||ddSt|dtt frFt |dkr;|\|_ |_ dS|d|_|dSdS)Nr.rr2) rslicerseqrcrFrZr$rrrYrr)r`vslicerr<r<r=rfss    zCronRange.__init__cCs8|ddkr6|d\}}z |j||_Wnty%d|_d}Ynw|jdks2|j|jjkr6td|ddkr|d\}}|jj|dd|_z |j||_ Wntyt|jdkrfd|_nd|_ |jj|dd|_ Ynw|j |jkrtd |jd|j d dS|d kr| dStd |d )z!Parse a ranged value in a cronjobrr.z0-0z*Sequence can not be divided by zero or maxrNrrr2z Bad range 'rrzUnknown cron range value ""N) rrUrrrrr(rrrrrc)r`rerrrr<r<r=r$s6     zCronRange.parsecCs|jj|_|jj|_dS)z.) rrrr)rr(rZrrr?rr)r`rrer<r<r=rs$    zCronRange.rendercCstt|jt|jd|jS)z7Returns the range of this cron slice as a iterable listr.)rrrrrrjr<r<r=rszCronRange.rangecCst||_dS)z&Set the sequence value for this range.N)rrrr<r<r=rEszCronRange.everycCst|jt|kSr;rrrr<r<r=rzCronRange.__lt__cCst|jt|kSr;)rrrr<r<r=rrzCronRange.__gt__cCrr;rrjr<r<r=ryrtzCronRange.__int__cCrr;rrjr<r<r=rsrzCronRange.__str__Nr)rrrrrfr$rcrrrErrryrsr<r<r<r=rqs  rcsHeZdZdZfddZeddZddZfdd Zd d Z Z S) ra4An ordered dictionary with a linked list containing the previous OrderedVariableList which this list depends. Duplicates in this list are weeded out in favour of the previous list in the chain. This is all in aid of the ENV variables list which must exist one per job in the chain. cs$|dd|_tj|i|dS)Nr)rVrrrf)r`r[rorr<r=rfszOrderedVariableList.__init__cCsP|jdur&|jjdur&|jjj|j}|dkr|jjjS|jj|djSdS)z8Returns the previous env in the list of jobs in the cronNrr.)rrrrrM)r`rr<r<r=previouss  zOrderedVariableList.previouscCs.|jdur|j}|||S|S)z| Returns the full dictionary, everything from this dictionary plus all those in the chain above us. N)rrrcrbr)r`rr<r<r=rcs  zOrderedVariableList.allcs>|j}||vr t|S|dur||Std|d)NzEnvironment Variable 'z ' not found.)rrrrcr8)r`rdrrr<r=rs   zOrderedVariableList.__getitem__cCs|g}|D]-\}}|jr|j|d|krqdt|vs#|dkr)d|d}||d|q|dd|S)z4Constructs to variable list output used in cron jobsNrrrrOr)rXrrcrdrZrr)r`rrdrer<r<r=rss   zOrderedVariableList.__str__) rrrrrfrrrcrrsrr<r<rr=rs   r)rFr)ArrArerTrrr3rplatform subprocessrgcalendarrrrrrr collectionsrshutilr __pkgname__ __version__compilerr0DEVNULL WEEK_ENUM MONTH_ENUMrrrsystemrr*rWunamer?r getLoggerr6rrardr:rCr?rKrLrrrCrrr8rrrrrrrrrr<r<r<r=sC              /h"L   Y