o eT @sJdZzddlmZWneyddlmZYnwddlmZddlZddlm Z m Z ddl m Z m Z mZmZddlmZddlmZmZdd lmZmZdd lmZdd lmZd d lmZmZd dl m!Z!d dl"m#Z#d dl$m%Z%m&Z&dZ'dZ(dZ)dZ*dZ+e'edfe(edfe)edfe*edfe+edffZ,e'edfe(edfe)edfe*edfe+edffZ-d ed!fd"ed#fd$ed%fd&ed'fd(ed)fd*ed+fd,ed-fd.ed/fd0ed1fg Z.d2d3Z/d4d5Z0Gd6d7d7ej1Z2Gd8d9d9ej1Z3Gd:d;d;ej1Z4Gdd?d?ej1Z6Gd@dAdAej1Z7dS)BzDatabase models.)available_timezones) timedeltaN) current_app schedules)FormatExceptionMissingFieldExceptionWrongArgumentExceptionget_description)settings)MultipleObjectsReturnedValidationError)MaxValueValidatorMinValueValidator)models) gettext_lazy) querysets validators)clocked)TzAwareCrontab make_awarenowdayshoursminutesseconds microsecondsDaysHoursMinutesSeconds MicrosecondsDayHourMinuteSecond Microseconddawn_astronomicalzAstronomical dawn dawn_civilz Civil dawn dawn_nauticalz Nautical dawndusk_astronomicalzAstronomical dusk dusk_civilz Civil dusk dusk_nauticalz Nautical dusk solar_noonz Solar noonsunriseSunrisesunsetSunsetcCs|r t|ddp dS)z"Representation of cron expression. *)strreplace)fieldr9K/var/www/html/env/lib/python3.10/site-packages/django_celery_beat/models.pycronexp;sr;cCs<z ttdtj}Wn tyYdSw|tvr|SdS)zReturn timezone string from Django settings ``CELERY_TIMEZONE`` variable. If is not defined or is not a valid timezone, return ``"UTC"`` instead. z %s_TIMEZONEUTC)getattrr r namespaceAttributeErrorr)CELERY_TIMEZONEr9r9r: crontab_schedule_celery_timezone@s   rAc@seZdZdZejdeededdZej ddeded e d e d gd Z ej dded ede de dgd Z GdddZeddZeddZddZdS) SolarSchedulezSchedule following astronomical patterns. Example: to run every sunrise in New York City: >>> event='sunrise', latitude=40.7128, longitude=74.0060 z Solar Eventz/The type of solar event when the job should run max_lengthchoices verbose_name help_text Latitudez4Run the task when the event happens at this latitudeiZ) max_digitsdecimal_placesrGrHr Longitudez5Run the task when the event happens at this longitudeiLc@s(eZdZdZedZedZdZdZdS)zSolarSchedule.MetaTable information.z solar eventz solar eventseventlatitude longitudeN) __name__ __module__ __qualname____doc___rGverbose_name_pluralorderingunique_togetherr9r9r9r:Metais r^cCstj|j|j|jdddS)NcS ttSNrr9r9r9r:v z(SolarSchedule.schedule..nowfun)rsolarrSrTrUselfr9r9r:scheduleqs zSolarSchedule.schedulecCsJ|j|j|jd}z |jjdi|WS|jy$|di|YSw)NrRr9)rSlatlonobjectsget DoesNotExistclsrhspecr9r9r: from_schedulexszSolarSchedule.from_schedulecCsd||j|jS)Nz {} ({}, {}))formatget_event_displayrTrUrfr9r9r:__str__s zSolarSchedule.__str__N)rVrWrXrYr CharFieldSOLAR_SCHEDULESrZrS DecimalFieldrr rTrUr^propertyrh classmethodrqrtr9r9r9r:rBOs2   rBc@seZdZdZeZeZeZeZeZe Z e j de de de dgdZe jde e de d d ZGd d d Zed dZeefddZddZeddZdS)IntervalSchedulezpSchedule executing on a regular interval. Example: execute every 2 days: >>> every=2, period=DAYS FzNumber of Periodsz@Number of interval periods to wait before running the task againr)nullrGrHrrCzInterval Periodz4The type of period between task runs (Example: days)rDc@s(eZdZdZedZedZddgZdS)zIntervalSchedule.MetarQinterval intervalsperiodeveryNrVrWrXrYrZrGr[r\r9r9r9r:r^  r^cCs$tjtdi|j|jidddS)NcSr_r`rr9r9r9r:rarbz+IntervalSchedule.schedule..rcr9)rrhrr~rrfr9r9r:rhszIntervalSchedule.schedulecCsht|jd}z |jj||dWS|jy!|||dYSty3|jj||dYSw)Nr)rr~) max run_every total_secondsrkrlrmr filterfirst)rorhr~rr9r9r:rqs zIntervalSchedule.from_schedulecCsvd}|jdkr tD]\}}||jkr|}nq td|StD]\}}||jkr1|}nq"td|j|S)Nrzevery {}z every {} {})rSINGULAR_PERIODSr~lowerrZrrPERIOD_CHOICES)rgreadable_periodr~_readable_periodr9r9r:rts     zIntervalSchedule.__str__cCs|jddS)N)r~rfr9r9r:period_singularsz IntervalSchedule.period_singularN)rVrWrXrYDAYSHOURSMINUTESSECONDS MICROSECONDSrr IntegerFieldrZrrrur~r^rxrhryrqrtrr9r9r9r:rzs6  rzc@sTeZdZdZejededdZGdddZddZ e d d Z e d d Z d S)ClockedSchedulezclocked schedule.z Clock TimezRun the task at clocked time)rGrHc@s&eZdZdZedZedZdgZdS)zClockedSchedule.MetarQr clocked_timeNrr9r9r9r:r^s  r^cCs t|jSr`)rrrfr9r9r:rts zClockedSchedule.__str__cCst|jd}|S)N)r)rr)rgcr9r9r:rhs zClockedSchedule.schedulecCshd|ji}z |jjdi|WS|jy |di|YSty3|jjdi|YSw)Nrr9)rrkrlrmr rrrnr9r9r:rqs  zClockedSchedule.from_scheduleN)rVrWrXrYr DateTimeFieldrZrr^rtrxrhryrqr9r9r9r:rs rc@seZdZdZejddededejgdZ ejddeded ej gdZ ejd ded ed ej gdZ ejd dededejgdZejd dededejgdZejedededdZGdddZeddZddZeddZeddZd S)!CrontabSchedulezTimezone Aware Crontab-like schedule. Example: Run every hour at 0 minutes for days of month 10-15: >>> minute="0", hour="*", day_of_week="*", ... day_of_month="10-15", month_of_year="*" r5z Minute(s)z9Cron Minutes to Run. Use "*" for "all". (Example: "0,30"))rEdefaultrGrHr`zHour(s)z7Cron Hours to Run. Use "*" for "all". (Example: "8,20")|zDay(s) Of The MonthzCCron Days Of The Month to Run. Use "*" for "all". (Example: "1,15")@zMonth(s) Of The YearzKCron Months (1-12) Of The Year to Run. Use "*" for "all". (Example: "1,12")zDay(s) Of The Weekz`Cron Days Of The Week to Run. Use "*" for "all", Sunday is 0 or 7, Monday is 1. (Example: "0,5")Fz Cron Timezonez5Timezone to Run the Cron Schedule on. Default is UTC.)ruse_pytzrGrHc@s(eZdZdZedZedZgdZdS)zCrontabSchedule.MetarQcrontabcrontabs) month_of_year day_of_month day_of_weekhourminutetimezoneNrr9r9r9r:r^6rr^c Cs~dt|jt|jt|jt|jt|j}zt|}Wntt t fy4|dt |j YSw|dt |j S)Nz{} {} {} {} {}r3) rrr;rrrrrr rrrr6r)rgcron_expressionhuman_readabler9r9r:r>s  zCrontabSchedule.human_readablec Cs8dt|jt|jt|jt|jt|jt|jS)Nz{} {} {} {} {} (m/h/dM/MY/d) {}) rrr;rrrrrr6rrfr9r9r:rtOs zCrontabSchedule.__str__cCsNtj|j|j|j|j|jd}ttddr%t |j|j|j|j|j|j d}|S)N)rrrrrDJANGO_CELERY_BEAT_TZ_AWARET)rrrrrtz) rrrrrrrr=r rr)rgrr9r9r:rhVs" zCrontabSchedule.schedulecCs||j|j|j|j|j|jd}z |jjdi|WS|jy*|di|YSt y=|jj di| YSw)N)rrrrrrr9) _orig_minute _orig_hour_orig_day_of_week_orig_day_of_month_orig_month_of_yearrrkrlrmr rrrnr9r9r:rqjs zCrontabSchedule.from_scheduleN)rVrWrXrYrrurZrminute_validatorrhour_validatorrday_of_month_validatorrmonth_of_year_validatorrday_of_week_validatorrtimezone_field TimeZoneFieldrArr^rxrrtrhryrqr9r9r9r:rst   rc@sPeZdZdZejddddZejddZe ddZ e d d Z e d d Z d S) PeriodicTasksaQHelper table for tracking updates to periodic tasks. This stores a single row with ``ident=1``. ``last_update`` is updated via signals whenever anything changes in the :class:`~.PeriodicTask` model. Basically this acts like a DB data audit trigger. Doing this so we also track deletions, and not just insert/update. rT)r primary_keyuniqueF)r{cKs|js |dSdSr`) no_changesupdate_changed)roinstancekwargsr9r9r:changeds zPeriodicTasks.changedcKs|jjddtiddS)Nr last_update)identdefaults)rkupdate_or_creater)rorr9r9r:rszPeriodicTasks.update_changedcCs*z |jjddjWS|jyYdSw)Nr)r)rkrlrrm)ror9r9r: last_changes zPeriodicTasks.last_changeN) rVrWrXrYrSmallIntegerFieldrrrryrrrr9r9r9r:r{s   rc seZdZdZejddededdZejddedd Zej e ej dded ed d Z ej e ej dded edd Zej eej ddededd Zej eej ddededd ZejddededdZejddededdZejddddededdZejddddededdZejdddded ed!dZejdded"ed#dZejded$gdded%ed&d'Zejdded(ed)d*Zejdded+ed,d*Zej d-ed.ed/d0Z!ejdded1ed2d*Z"ej ded3ed4d0Z#ejd-d-d-dded5ed6d7Z$ejd8d-ed9ed:d;Z%ejded<ed=d>Z&ejded?ed@dAZ'e(j)*Z+d-Z,GdBdCdCZ-fdDdEZ.fdFdGZ/fdHdIZ0dJdKZ1e2dLdMZ3dNdOZ4e2dPdQZ5e2dRdSZ6Z7S)T PeriodicTaskz#Model representing a periodic task.TNamezShort Description For This Task)rErrGrHz Task NamezXThe Name of the Celery Task that Should be Run. (Example: "proj.tasks.import_contacts"))rErGrHzInterval SchedulezYInterval Schedule to run the task on. Set only one schedule type, leave the others null.) on_deleter{blankrGrHzCrontab SchedulezXCrontab Schedule to run the task on. Set only one schedule type, leave the others null.zSolar SchedulezVSolar Schedule to run the task on. Set only one schedule type, leave the others null.zClocked SchedulezXClocked Schedule to run the task on. Set only one schedule type, leave the others null.z[]zPositional Argumentsz=JSON encoded positional arguments (Example: ["arg1", "arg2"]))rrrGrHz{}zKeyword Argumentsz?JSON encoded keyword arguments (Example: {"argument": "value"})NzQueue OverridezDQueue defined in CELERY_TASK_QUEUES. Leave None for default queuing.)rErr{rrGrHExchangez,Override Exchange for low-level AMQP routingz Routing Keyz/Override Routing Key for low-level AMQP routingzAMQP Message Headersz2JSON encoded message headers for the AMQP message.PriorityzcPriority Number between 0 and 255. Supported by: RabbitMQ, Redis (priority reversed, 0 is highest).)rrrr{rGrHzExpires DatetimezHDatetime after which the schedule will no longer trigger the task to run)rr{rGrHzExpires timedelta with secondszPTimedelta with seconds which the schedule will no longer trigger the task to runFz One-off Taskz:If True, the schedule will only run the task a single time)rrGrHzStart DatetimezBDatetime when the schedule should begin triggering the task to runEnabledz$Set to False to disable the schedulezLast Run DatetimezdDatetime that the schedule last triggered the task to run. Reset to None if enabled is set to False.)auto_now auto_now_addeditablerr{rGrHrzTotal Run CountzCRunning count of how many times the schedule has triggered the task)rrrGrHz Last Modifiedz1Datetime that this PeriodicTask was last modified)rrGrH Descriptionz=s z0PeriodicTask.validate_unique..rz8One of clocked, interval, crontab, or solar must be set.zsn                         >H"