a Кxd√8у<@s6dZddlmZmZddlmZddlmZddlm Z dZ dZdgZd а бZd ZdZdhZd hZdhZeddГZdНddДZddДZGddДdГZeeededНedddНedddНeddedНeddedНededНeeedd dНeid!dНed"Гed#Гedd$dНd%НeedddНedddНedddНeddНeid!dНed&d dНedddНed'd$dНedddНed(d$dНed)d$dНedddНed*d$dНed+ddНeddНed$dНeddНeddНeddНd,Нeed-ГeГeid!dНd.Нeed dНeddНeddНeddНeddНeddНeddНeddНeddНeid!dНd/Н eeddНeddНeddНeddНeddНeddНd0Нeed1ddНed2d$dНed2d$dНed3d$dНed4ddНd5Нeed6d dНed7d dНed1ddНd8Нeed9Гedd!dНd:Нeed;Гedd!dНd:Нeed<Гed!dНd:Нeed=ddНed>ddНed?ddНed@d$dНedAd$dНdBНeedCГedDd dНedEd dНedFГedГedFddНdGНeedHГed!dНed$dНeddНed$dНeddНeddНed$dНedId dНedd dНed+ddНed+ddНdJНeedKГeddНedLd$dMhdНedNdНedOГedPГeedQdRНd dShdНedddНed+ddНedГeid!dНedTd dНed)d dНedUd$dНeedVГd dНed*d$dНed+ddНdWНeedXГeddНed$dНed dНedddНdYНeedZГeddНeddНeddНeeddНd[Нeed\hd]Нed!d^hdНed+dd_hdНed!dНed!d`hdНdaНeeed+ddНedddНed+ddНedbdНeddchdНedddНed+ddНed2ddНed1ГedddНedPГedddНeddНedddНed+dddhdНed+ddНed+ddНed2d$dehdНedddfhdНed3ddQdgdhЬd!dihdНed!dНedd$dНeddНed+ddНedbdНed+ddjhdНeddkhd]Нed dlhdНed dmhdНed+ddНed+ddНdnН eeedddНedoГed+ddНedd$dНedpddНed+ddqhdНed+ddrhdНed+ddНedddshdНedddНeddНeeГed7d dthdНed$dНed$dНeeГedddНed+ddНedud dНed&d$dНedddvhdНedwdxhd]Нed+ddyhdНeГeeГeddНedTd dНdzНd{НZd|d}ДZd~dДZd4efdАdБДZdВdГДeeГDГZeeeedДНГZdЕdГДeDГZ dЖdГДeDГZ!dЗdГДeDГZ"dZe#eа$бГZ%e#e"а$бГZ&dИdЙДZ'eddКНdОdЛdМДГZ(dS)Пz)Configuration introspection and defaults.щ)┌deque┌ namedtuple)┌ timedelta)┌memoize)┌ strtobool)┌Option┌ NAMESPACES┌flatten┌findZprefork┌jsonz> [%(asctime)s: %(levelname)s/%(processName)s] %(message)s zT[%(asctime)s: %(levelname)s/%(processName)s] %(task_name)s[%(task_id)s]: %(message)s┌sha256z celery_{0}zcelerybeat_{0}zceleryd_{0}┌searchresult)┌ namespace┌key┌typeNcs8|dur4|абD]"\Й}|jsЗfddД|DГ|_q|S)Ncsh|]}|аИбТqSй)┌format)┌.0┌oйrr·K/var/www/html/Ranjet/env/lib/python3.9/site-packages/celery/app/defaults.py┌ "єzNamespace..)┌items┌old)┌__old__┌options┌optrrr┌ Namespaces rcCs|ЫdЭhS)Nz_{0}r)┌nsrrr┌old_ns&sr c@sTeZdZdZdZdZdZeГZe e eddДee edЬZdddДZdd ДZd dДZdS) rz(Describes a Celery configuration option.NcCs|SйNr)┌vrrr┌1rzOption.)┌string┌int┌float┌any┌bool┌dict┌tuplecOs8||_|аdбpd|_|абD]\}}t|||ГqdS)Nrr$)┌default┌getrr┌setattr)┌selfr+┌args┌kwargs┌attr┌valuerrr┌__init__4szOption.__init__cCs|j|j|ГSr!)┌typemapr)r.r2rrr┌ to_python:szOption.to_pythoncCsdа|j|jбS)Nz {} default->{!r}>)rrr+)r.rrr┌__repr__=s zOption.__repr__)N)┌__name__┌ __module__┌__qualname__┌__doc__┌alt┌deprecate_by┌ remove_by┌setr┌strr%r&rr)r*r4r3r5r6rrrrr*s r┌list)rr)rTr(rr*r$r&r)zcelery.beat:PersistentSchedulerzcelerybeat-scheduler%)rZmax_loop_interval┌scheduleZ schedulerZschedule_filenameZ sync_everyщщdщxg@щ F)┌urlZread_urlZ write_url┌ transportZtransport_optionsZconnection_timeoutZconnection_retryZconnection_max_retriesZfailover_strategyZ heartbeatZheartbeat_checkrateZlogin_methodZ pool_limitZuse_ssl┌host┌port┌user┌passwordZvhostZcelery_cache)r┌backendZbackend_options) Z entry_ttlZkeyspacerIZread_consistencyZservers┌tableZwrite_consistencyZ auth_providerZauth_kwargsr)Z access_key_idZsecret_access_keyZbucket┌ base_pathZendpoint_urlZregion┌celeryщщ┌)Zcontainer_nameZretry_initial_backoff_secZretry_increment_baseZretry_max_attemptsrNg└r@g$@)┌ queue_ttl┌ queue_expires┌exchangeZcelery_couchbase)rZbackend_settingsZcelery_arangodbZcelery_mongodbZcelerydbZ celerycol┌Sessionщ щ)Z database_nameZcollection_nameZconsistency_levelZmax_retry_attemptsZmax_retry_wait_timeZcelery_eventgN@g@Zceleryev)rrTrSZqueue_prefix┌ serializerrUZcelery_redisg^@)rZbackend_use_ssl┌dbrHZmax_connections┌usernamerKrI┌socket_timeoutZsocket_connect_timeout┌retry_on_timeoutZsocket_keepaliveZ celery_resultщ Zcelery_max_cached_resultsr?Z celeryresults┌directщ)┌daysZcelery_task_result_expiresgЁ?i'┌inf)rrLZ cache_max┌compressionrUZ exchange_type┌expires┌ persistent┌extendedrYZbackend_transport_optionsZchord_retry_intervalZchord_join_timeoutZ$backend_max_sleep_between_retries_msZbackend_max_retriesZ%backend_base_sleep_between_retries_msZbackend_always_retryZcelery_elasticsearch)rr]┌max_retries┌timeoutZsave_meta_as_textZcelery_security)rZcertificateZ cert_storer┌digestZcelery_result_dburi)rZcelery_result_engine_optionsZ%celery_result_db_short_lived_sessionsZcelery_result_db_tablenames)rFZengine_optionsZshort_lived_sessionsZ table_schemasZtable_namesr'Zcelery_message_compressionZ"celery_eager_propagates_exceptionsZcelery_task_protocolZcelery_task_publish_retrygЪЩЩЩЩЩ╔?)rgZinterval_startZinterval_maxZ interval_stepZ celery_task_publish_retry_policyZcelery_send_task_sent_eventZcelery_task_serializerZceleryd_task_soft_time_limitZceleryd_task_time_limit) rZ acks_lateZacks_on_failure_or_timeoutZalways_eager┌annotationsrcZcreate_missing_queuesZinherit_parent_priorityZdefault_delivery_modeZ default_queueZdefault_exchangeZdefault_exchange_typeZdefault_routing_keyZdefault_rate_limitZdefault_priorityZeager_propagatesZ ignore_resultZstore_eager_result┌protocolZ publish_retryZpublish_retry_policyZqueuesZqueue_max_priorityZreject_on_worker_lostZremote_tracebacksZroutesZsend_sent_eventrYZsoft_time_limitZ time_limitZstore_errors_even_if_ignoredZ track_startedz"celery.worker.autoscale:Autoscalerzcelery.worker.consumer:ConsumerZcelery_worker_directZcelery_disable_rate_limitsZcelery_enable_remote_controlZceleryd_worker_lost_waitg@Zcelery_redirect_stdouts┌WARNINGZcelery_redirect_stdouts_levelZcelery_send_events)rZagentZ autoscalerZ,cancel_long_running_tasks_on_connection_lossZconcurrencyZconsumerr_Zdisable_rate_limitsZdeduplicate_successful_tasksZenable_remote_controlZhijack_root_loggerZ log_colorZ log_formatZ lost_waitZmax_memory_per_childZmax_tasks_per_child┌poolZ pool_putlocksZ pool_restartsZproc_alive_timeoutZprefetch_multiplierZredirect_stdoutsZredirect_stdouts_levelZsend_task_eventsZstate_dbZtask_log_formatZtimerZtimer_precision)Zaccept_contentZresult_accept_contentZ enable_utcZimports┌include┌timezoneZbeatZbroker┌cacheZ cassandraZs3Zazureblockblob┌controlZ couchbaseZarangodbZmongodbZcosmosdbsql┌eventZredis┌resultZ elasticsearch┌securityZdatabaseZtaskZworkercCs|||fgSr!rйrrrrrr┌ _flatten_keysQsrvcs6ИjrЗЗЗfddДИjDГSИИабИИИfgS)Ncs$g|]}|аИбабИИИfСqSr)r┌upper)rZoldkeyйrrrrr┌ Ws z_to_compat..)rrwrurrxr┌ _to_compatUs ■rzccsjt||fgГ}|rf|аб\}}|абD]<\}}t|tГrP|а||d|fбq&||||ГEdHq&qdS)zFlatten settings.┌_N)r┌popleftr┌ isinstancer)┌append)┌d┌root┌ keyfilter┌stackrrrrrrrr ^s r cCsi|]\}}||jУqSrйr+)rrrrrr┌ jsrД)rБcCsi|]\}}}||jУqSrrГ)r┌old_keyr{rrrrrДnrcCsi|]\}}}||УqSrrйrrЕZnew_keyr{rrrrДorcCsi|]\}}}||УqSrrrЖrrrrДprcCsbddlm}ttГD]H\}}|js(|jrt||dГr|jd|ЫdЭ|j|jd|jЫdЭdНq|S)Nr)┌ deprecatedzThe z settingzUse the z instead)┌description┌deprecationZremoval┌alternative) Zcelery.utilsrЗr rr<r=┌getattr┌warnr;)┌sourcerЗ┌namerrrr┌find_deprecated_settingsws¤rП)┌maxsizecCs╚|аб}zt||абt||абГWStyоtабD]l\}}|аб|абkrhtd||ГYSt|tГr┌keysZSETTING_KEYSZ_OLD_SETTING_KEYSrПr rrrr┌sP ∙ ь № Ў· √ ¤ ¤ ■¤ √ ∙ є■■ ш · · ў ¤√ ╨2 ╓Аа