o wvXjQ@sndZddlmZddlZddlmZddlmZddlm Z m Z ddl m Z m Z ddlmZdd lmZdd lmZd d lmZmZd d lmZd dlmZmZd dlmZdZdZ dZ!dZ"dZ#eedfe edfe!edfe"edfe#edffZ$eedfe edfe!edfe"edfe#edffZ%dd e&ej'j(DZ)d!d"Z*Gd#d$d$ej+Z,Gd%d&d&ej+Z-Gd'd(d(ej+Z.Gd)d*d*ej+Z/Gd+d,d,ej+Z0Gd-d.d.ej+Z1ej2j3e0j4e1d/ej5j3e0j4e1d/ej2j3e0j6e-d/ej7j3e0j6e-d/ej8j3e0j6e/d/ej7j3e0j6e/d/ej8j3e0j6e,d/ej7j3e0j6e,d/ej8j3e0j6e.d/ej7j3e0j6e.d/dS)0zDatabase models.) timedeltaN) schedules)settings)MultipleObjectsReturnedValidationError)MaxValueValidatorMinValueValidator)models)signals) gettext_lazy)managers validators)TzAwareCrontab make_awarenow)clockeddayshoursminutesseconds microsecondsDaysHoursMinutesSeconds MicrosecondsDayHourMinuteSecond MicrosecondcCsg|]}|t|fqS)_).0xr#r#V/var/www/html/myproject/venv/lib/python3.10/site-packages/django_celery_beat/models.py )sr(cCs|r t|ddp dS)z"Representation of cron expression. *)strreplace)fieldr#r#r'cronexp,sr/c@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_placesr5r6r 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__r$r5verbose_name_pluralorderingunique_togetherr#r#r#r'MetaJs rKcCstj|j|j|jdddS)NcS ttSNrr#r#r#r'W z(SolarSchedule.schedule..nowfun)rsolarrArBrCselfr#r#r'scheduleRs zSolarSchedule.schedulecCs~|j|j|jd}z |jjdi|WS|jy$|di|YSty>|jjdi||di|YSw)Nr@r#) rAlatlonobjectsget DoesNotExistrfilterdeleteclsrUspecr#r#r' from_scheduleYs zSolarSchedule.from_schedulecCsd||j|jS)Nz{0} ({1}, {2}))formatget_event_displayrBrCrSr#r#r'__str__fs zSolarSchedule.__str__N)rDrErFrGr CharFieldSOLAR_SCHEDULESr$rA DecimalFieldrrrBrCrKpropertyrU classmethodr`rcr#r#r#r'r01s2   r0c@seZdZdZeZeZeZeZeZe Z e j de de de dgdZe jde e de d d ZGd d d Zed dZeefddZddZeddZdS)IntervalSchedulezjSchedule 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 )nullr5r6rr1zInterval Periodz4The type of period between task runs (Example: days)r2c@s(eZdZdZedZedZddgZdS)zIntervalSchedule.Metar?interval intervalsperiodeveryNrDrErFrGr$r5rHrIr#r#r#r'rK  rKcCs$tjtdi|j|jidddS)NcSrLrMrr#r#r#r'rNrOz+IntervalSchedule.schedule..rPr#)rrUrrmrnrSr#r#r'rUszIntervalSchedule.schedulecCstt|jd}z |jj||dWS|jy!|||dYSty9|jj||d|||dYSw)Nr)rnrm) max run_every total_secondsrXrYrZrr[r\)r^rUrmrnr#r#r'r`s zIntervalSchedule.from_schedulecCsvd}|jdkr tD]\}}||jkr|}nq td|StD]\}}||jkr1|}nq"td|j|S)Nr zevery {}z every {} {})rnSINGULAR_PERIODSrmlowerr$raPERIOD_CHOICES)rTreadable_periodrm_readable_periodr#r#r'rcs     zIntervalSchedule.__str__cCs|jddS)N)rmrSr#r#r'period_singularsz IntervalSchedule.period_singularN)rDrErFrGDAYSHOURSMINUTESSECONDS MICROSECONDSrvr IntegerFieldr$rrnrdrmrKrgrUrhr`rcrzr#r#r#r'rins6  ric@sneZdZdZejededdZejddededd Z Gd d d Z d d Z e ddZ eddZdS)ClockedSchedulezclocked schedule.z Clock TimezRun the task at clocked time)r5r6TFEnabled$Set to False to disable the scheduledefaulteditabler5r6c@s&eZdZdZedZedZdgZdS)zClockedSchedule.Metar?r clocked_timeNror#r#r#r'rKs  rKcCsd|j|jS)Nz{} {})rarenabledrSr#r#r'rcszClockedSchedule.__str__cCst|j|j|d}|S)N)rrmodel)rrr)rTcr#r#r'rUszClockedSchedule.schedulecCsz|j|jd}z |jjdi|WS|jy"|di|YSty<|jjdi||di|YSw)N)rrr#)rrrXrYrZrr[r\r]r#r#r'r`s zClockedSchedule.from_scheduleN)rDrErFrGr DateTimeFieldr$r BooleanFieldrrKrcrgrUrhr`r#r#r#r'rs$ rc@seZdZdZejddededejgdZ ejddeded ej gdZ ejd ded ed ej gdZ ejd dededejgdZejd dededejgdZejdededdZGdddZddZeddZeddZdS)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="*" r+z Minute(s)z9Cron Minutes to Run. Use "*" for "all". (Example: "0,30"))r3rr5r6r`zHour(s)z7Cron Hours to Run. Use "*" for "all". (Example: "8,20")@zDay(s) Of The WeekzACron Days Of The Week to Run. Use "*" for "all". (Example: "0,5")|zDay(s) Of The MonthzCCron Days Of The Month to Run. Use "*" for "all". (Example: "1,15")zMonth(s) Of The YearzCCron Months Of The Year to Run. Use "*" for "all". (Example: "0,6")UTCz Cron Timezonez6Timezone to Run the Cron Schedule on. Default is UTC.rr5r6c@s(eZdZdZedZedZgdZdS)zCrontabSchedule.Metar?crontabcrontabs) month_of_year day_of_month day_of_weekhourminutetimezoneNror#r#r#r'rKrprKc Cs8dt|jt|jt|jt|jt|jt|jS)Nz%{0} {1} {2} {3} {4} (m/h/d/dM/MY) {5}) rar/rrrrrr,rrSr#r#r'rc&s 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) rrrrrrrgetattrrrr)rTrr#r#r'rU-s" zCrontabSchedule.schedulecCs|j|j|j|j|j|jd}z |jjdi|WS|jy*|di|YSt yD|jj di| |di|YSw)N)rrrrrrr#) _orig_minute _orig_hour_orig_day_of_week_orig_day_of_month_orig_month_of_yearrrXrYrZrr[r\r]r#r#r'r`As zCrontabSchedule.from_scheduleN)rDrErFrGr rdr$rminute_validatorrhour_validatorrday_of_week_validatorrday_of_month_validatorrmonth_of_year_validatorrtimezone_field TimeZoneFieldrrKrcrgrUrhr`r#r#r#r'rsn  rc@sXeZdZdZejddddZejddZe Z e ddZ e d d Ze d d Zd S) PeriodicTasksaIHelper table for tracking updates to periodic tasks. This stores a single row with ident=1. last_update is updated via django signals whenever anything is changed in the PeriodicTask model. Basically this acts like a DB data audit trigger. Doing this so we also track deletions, and not just insert/update. r T)r primary_keyuniqueF)rjcKs|js |dSdSrM) no_changesupdate_changed)r^instancekwargsr#r#r'changedas zPeriodicTasks.changedcKs|jjddtiddS)Nr last_update)identdefaults)rXupdate_or_creater)r^rr#r#r'rfszPeriodicTasks.update_changedcCs*z |jjddjWS|jyYdSw)Nr )r)rXrYrrZ)r^r#r#r' last_changejs zPeriodicTasks.last_changeN)rDrErFrGr SmallIntegerFieldrrrr ExtendedManagerrXrhrrrr#r#r#r'rSs   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()Z*d-Z+GdBdCdCZ,fdDdEZ-fdFdGZ.dHdIZ/e0dJdKZ1dLdMZ2e0dNdOZ3Z4S)P PeriodicTaskz#Model representing a periodic task.TNamezShort Description For This Task)r3rr5r6z Task NamezXThe Name of the Celery Task that Should be Run. (Example: "proj.tasks.import_contacts"))r3r5r6zInterval SchedulezYInterval Schedule to run the task on. Set only one schedule type, leave the others null.) on_deleterjblankr5r6zCrontab 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"]))rrr5r6z{}zKeyword Argumentsz?JSON encoded keyword arguments (Example: {"argument": "value"})NzQueue OverridezDQueue defined in CELERY_TASK_QUEUES. Leave None for default queuing.)r3rrjrr5r6Exchangez,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).)rrrrjr5r6zExpires DatetimezHDatetime after which the schedule will no longer trigger the task to run)rrjr5r6zExpires 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 timerzStart DatetimezBDatetime when the schedule should begin triggering the task to runrrzLast Run DatetimezdDatetime that the schedule last triggered the task to run. Reset to None if enabled is set to False.)auto_now auto_now_addrrrjr5r6rzTotal Run CountzCRunning count of how many times the schedule has triggered the taskrz Last Modifiedz1Datetime that this PeriodicTask was last modified)rr5r6 Descriptionz.rrkz8One of clocked, interval, crontab, or solar must be set.zs                 =H+rj