a xdXS @sdZddlmZddlZddlmZmZddlmZddl m Z m Z ddl m Z mZddlmZdd lmZdd lmZd d lmZmZd d lmZd dlmZmZd dlmZdZ dZ!dZ"dZ#dZ$e edfe!edfe"edfe#edfe$edffZ%e edfe!edfe"edfe#edfe$edffZ&ded fd!ed"fd#ed$fd%ed&fd'ed(fd)ed*fd+ed,fd-ed.fd/ed0fg Z'd1d2Z(d3d4Z)Gd5d6d6ej*Z+Gd7d8d8ej*Z,Gd9d:d:ej*Z-Gd;d<dd>ej*Z/Gd?d@d@ej*Z0ej1j2e/j3e0dAej4j2e/j3e0dAej1j2e/j5e,dAej6j2e/j5e,dAej7j2e/j5e.dAej6j2e/j5e.dAej7j2e/j5e+dAej6j2e/j5e+dAej7j2e/j5e-dAej6j2e/j5e-dAdS)BzDatabase models.) timedeltaN) schedules current_app)settings)MultipleObjectsReturnedValidationError)MaxValueValidatorMinValueValidator)models)signals) gettext_lazy)managers validators)TzAwareCrontab make_awarenow)clockeddayshoursminutesseconds microsecondsZDaysZHoursZMinutesZSecondsZ MicrosecondsZDayZHourZMinuteZSecondZ MicrosecondZdawn_astronomicalzAstronomical dawnZ dawn_civilz Civil dawnZ dawn_nauticalz Nautical dawnZdusk_astronomicalzAstronomical duskZ dusk_civilz Civil duskZ dusk_nauticalz Nautical duskZ solar_noonz Solar noonZsunriseZSunriseZsunsetZSunsetcCs|rt|ddpdS)z"Representation of cron expression. *)strreplace)fieldr Q/var/www/html/Ranjet/env/lib/python3.9/site-packages/django_celery_beat/models.pycronexp6sr"cCsHzttdtj}Wnty(YdS0|ddtjjDvrD|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_TIMEZONEUTCcSsg|]}|djqS)r)zone).0choicer r r! Esz4crontab_schedule_celery_timezone..)getattrrr namespaceAttributeErrortimezone_field TimeZoneFieldZdefault_choices)ZCELERY_TIMEZONEr r r! crontab_schedule_celery_timezone;s   r-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 ZLatitudez4Run the task when the event happens at this latitudeiZ)Z max_digitsZdecimal_placesr3r4rZ 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___r3verbose_name_pluralorderingZunique_togetherr r r r!Metads rEcCstj|j|j|jdddS)NcSs ttSNrr r r r!qz(SolarSchedule.schedule..Znowfun)rsolarr;r<r=selfr r r!schedulels zSolarSchedule.schedulecCsN|j|j|jd}z|jjfi|WS|jyH|fi|YS0dS)Nr:)r;ZlatZlonobjectsget DoesNotExistclsrMspecr r r! from_schedulesszSolarSchedule.from_schedulecCsd||j|jS)Nz{0} ({1}, {2}))formatZget_event_displayr<r=rKr r r!__str__s zSolarSchedule.__str__N)r>r?r@rAr CharFieldSOLAR_SCHEDULESrBr;Z DecimalFieldr rr<r=rEpropertyrM classmethodrTrVr r r r!r.Ks0  r.c@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 )nullr3r4rr/zInterval Periodz4The type of period between task runs (Example: days)r0c@s(eZdZdZedZedZddgZdS)zIntervalSchedule.Metar9intervalZ intervalsperiodeveryNr>r?r@rArBr3rCrDr r r r!rEsrEcCs$tjtfi|j|jidddS)NcSs ttSrFrr r r r!rGrHz+IntervalSchedule.schedule..rI)rrMrr^r_rKr r r!rMszIntervalSchedule.schedulecCslt|jd}z|jj||dWS|jyB|||dYStyf|jj||dYS0dS)Nr)r_r^) maxZ run_every total_secondsrNrOrPrfilterfirst)rRrMr^r_r r r!rTs zIntervalSchedule.from_schedulecCsvd}|jdkr@tD]\}}||jkr|}q2qtd|StD]\}}||jkrD|}qdqDtd|j|S)Nr zevery {}z every {} {})r_SINGULAR_PERIODSr^lowerrBrUPERIOD_CHOICES)rLZreadable_periodr^Z_readable_periodr r r!rVs     zIntervalSchedule.__str__cCs|jddS)N)r^rKr r r!period_singularsz IntervalSchedule.period_singularN)r>r?r@rADAYSHOURSMINUTESSECONDS MICROSECONDSrgr Z IntegerFieldrBr r_rWr^rErYrMrZrTrVrir r r r!r[s4  r[c@sTeZdZdZejededdZGdddZddZ e d d Z e d d Z d S)ClockedSchedulezclocked schedule.z Clock TimezRun the task at clocked time)r3r4c@s&eZdZdZedZedZdgZdS)zClockedSchedule.Metar9r clocked_timeNr`r r r r!rEsrEcCs d|jS)N{})rUrprKr r r!rVszClockedSchedule.__str__cCst|jd}|S)N)rp)rrp)rLcr r r!rMs zClockedSchedule.schedulecCsld|ji}z|jjfi|WS|jy@|fi|YStyf|jjfi|YS0dS)Nrp)rprNrOrPrrcrdrQr r r!rTs  zClockedSchedule.from_scheduleN)r>r?r@rAr DateTimeFieldrBrprErVrYrMrZrTr r r r!ros roc@seZdZdZejddededejgdZ ejddeded ej gdZ ejd ded ed ej gdZ ejd dededejgdZejd dededejgdZejeededdZGdddZddZeddZeddZdS)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="*" rz Minute(s)z9Cron Minutes to Run. Use "*" for "all". (Example: "0,30"))r1defaultr3r4r`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")z Cron Timezonez5Timezone to Run the Cron Schedule on. Default is UTC.rvr3r4c@s(eZdZdZedZedZgdZdS)zCrontabSchedule.Metar9crontabZcrontabs) month_of_year day_of_month day_of_weekhourminutetimezoneNr`r r r r!rE.srEc Cs8dt|jt|jt|jt|jt|jt|jS)Nz%{0} {1} {2} {3} {4} (m/h/dM/MY/d) {5}) rUr"rrr}r|r~rrrKr r r!rV6s zCrontabSchedule.__str__cCsNtj|j|j|j|j|jd}ttddrJt |j|j|j|j|j|j d}|S)N)rrr~r}r|ZDJANGO_CELERY_BEAT_TZ_AWARET)rrr~r}r|tz) rr{rrr~r}r|r(rrr)rLr{r r r!rM=s" zCrontabSchedule.schedulecCs|j|j|j|j|j|jd}z|jjfi|WS|jyT|fi|YSt yz|jj fi| YS0dS)N)rrr~r}r|r) Z _orig_minuteZ _orig_hourZ_orig_day_of_weekZ_orig_day_of_monthZ_orig_month_of_yearrrNrOrPrrcrdrQr r r!rTQs zCrontabSchedule.from_scheduleN)r>r?r@rAr rWrBrZminute_validatorrZhour_validatorrZday_of_week_validatorr~Zday_of_month_validatorr}Zmonth_of_year_validatorr|r+r,r-rrErVrYrMrZrTr r r r!rtsl  rtc@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)rvZ primary_keyuniqueF)r\cKs|js|dSrF) no_changesupdate_changed)rRinstancekwargsr r r!changedpszPeriodicTasks.changedcKs|jjddtiddS)Nr last_update)identdefaults)rNZupdate_or_creater)rRrr r r!ruszPeriodicTasks.update_changedcCs,z|jjddjWS|jy&Yn0dS)Nr )r)rNrOrrP)rRr r r! last_changeyszPeriodicTasks.last_changeN)r>r?r@rAr ZSmallIntegerFieldrrsrrZExtendedManagerrNrZrrrr r r r!rbs   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)r1rr3r4z Task NamezXThe Name of the Celery Task that Should be Run. (Example: "proj.tasks.import_contacts"))r1r3r4zInterval SchedulezYInterval Schedule to run the task on. Set only one schedule type, leave the others null.)Z on_deleter\blankr3r4zCrontab 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"]))rrvr3r4rqzKeyword Argumentsz?JSON encoded keyword arguments (Example: {"argument": "value"})NzQueue OverridezDQueue defined in CELERY_TASK_QUEUES. Leave None for default queuing.)r1rr\rvr3r4ZExchangez,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.ZPriorityzcPriority Number between 0 and 255. Supported by: RabbitMQ, Redis (priority reversed, 0 is highest).)rvrrr\r3r4zExpires DatetimezHDatetime after which the schedule will no longer trigger the task to run)rr\r3r4zExpires 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 timerzzStart DatetimezBDatetime when the schedule should begin triggering the task to runZEnabledz$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_nowZ auto_now_addeditablerr\r3r4rzTotal Run CountzCRunning count of how many times the schedule has triggered the task)rvrr3r4z Last Modifiedz1Datetime that this PeriodicTask was last modified)rr3r4 Descriptionzr?r@rArBr3rCr r r r!rEsrEcstj|i|gd}fdd|D}t|dkr@tdd}t|dkrpi}|D]}|g||<qXt|jrjsd}t|dS) N)r]r{rJrcsg|]}t|r|qSr )r()r%srKr r!r'&s z0PeriodicTask.validate_unique..rz8One of clocked, interval, crontab, or solar must be set.zr?r@rAr rWrBnameZtaskZ ForeignKeyr[ZCASCADEr]rtr{r.rJrorZ TextFieldrrrrrrZPositiveIntegerFieldrpriorityrsrrZ BooleanFieldr start_timerrZtotal_run_countZ date_changed descriptionrZPeriodicTaskManagerrNrrErrrrYrrVrM __classcell__r r rr!rs$           r)Zsender)8rAdatetimerr+ZceleryrrZ django.confrZdjango.core.exceptionsrrZdjango.core.validatorsrr Z django.dbr Zdjango.db.modelsr Zdjango.utils.translationr rBrrrZ tzcrontabrutilsrrZclockedschedulerrjrkrlrmrnrgrerXr"r-ZModelr.r[rortrrZ pre_deleteconnectrZpre_saverZ post_saveZ post_deleter r r r!s                           =G"qi