U Йd_9у<@sJdZddlmZmZddlmZddlmZddlm 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Нed5d$dНed(d$dНd6Нeed7d dНed8d dНed1ddНd9Нeed:Гedd!dНd;Нeed<Гedd!dНd;Нeed=Гed!dНd;Нeed>ddНed?ddНed@ddНedAd$dНedBd$dНdCНeedDГedEd dНedFd dНedGГedГedGddНdHНeedIГed!dНed$dНeddНed$dНeddНeddНed$dНedJd dНedd dНed+ddНed+ddНdKНeedLГeddНedMd$dNhdНedOdНedPГedQГeedRdSНd dThdНedddНed+ddНedГeid!dНedUd dНed)d dНedVd$dНeedWГd dНed*d$dНed+ddНdXНeedYГeddНed$dНed dНedddНdZНeed[ГeddНeddНeddНeeddНd\Нeed]hd^Нed!d_hdНed+dd`hdНed!dНed!dahdНdbНeeed+ddНedddНed+ddНedcdНedddhdНedddНed+ddНed2ddНed1ГedddНedQГedddНeddНedddНed+ddehdНed+ddНed+ddНed2d$dfhdНedddghdНed3ddRdhdiЬd!djhdНed!dНedd$dНeddНed+ddНedcdНed+ddkhdНeddlhd^Нed dmhdНed dnhdНed+ddНed+ddНdoН eeedddНedpГed+ddНedd$dНedqddНed+ddrhdНed+ddshdНed+ddНedddthdНedddНeddНeeГed8d duhdНed$dНed$dНeeГedddНed+ddНedvd dНed&d$dНedddwhdНedxdyhd^Нed+ddzhdНeГeeГeddНedUd dНd{Нd|НZd}d~ДZddАД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|dk r4|абD]"\Й}|jsЗfddД|DГ|_q|S)Ncsh|]}|аИбТqSй)┌format)┌.0┌oйrr·7/tmp/pip-unpacked-wheel-mu1yl971/celery/app/defaults.py┌ "szNamespace..)┌items┌old)┌__old__┌options┌optrrr┌ Namespaces rcCs|ЫdЭhS)Nz_{0}r)┌nsrrr┌old_ns&src@sTeZdZdZdZdZdZeГZe e eddДee edЬZdddДZdd ДZd dДZdS) rz(Describes a Celery configuration option.NcCs|SйNr)┌vrrr┌1єzOption.)┌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_options┌connection_timeoutZconnection_retryZconnection_max_retriesZfailover_strategyZ heartbeatZheartbeat_checkrateZlogin_methodZ pool_limitZuse_ssl┌host┌port┌user┌passwordZvhostZcelery_cache)r┌backendZbackend_options) Z entry_ttlZkeyspacerJZread_consistencyZservers┌tableZwrite_consistencyZ auth_providerZauth_kwargsr)Z access_key_idZsecret_access_keyZbucket┌ base_pathZendpoint_urlZregion┌celeryщщ┌щ)Zcontainer_nameZretry_initial_backoff_secZretry_increment_baseZretry_max_attemptsrOrH┌read_timeoutg└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)rrWrVZqueue_prefix┌ serializerrXZcelery_redisg^@)rZbackend_use_ssl┌dbrIZmax_connections┌usernamerLrJ┌socket_timeoutZsocket_connect_timeout┌retry_on_timeoutZsocket_keepaliveZ celery_resultщ Zcelery_max_cached_resultsr?Z celeryresults┌directщ)┌daysZcelery_task_result_expiresgЁ?i'┌inf)rrMZ cache_max┌compressionrXZ exchange_type┌expires┌ persistent┌extendedr\Zbackend_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ЪЩЩЩЩЩ╔?)rjZinterval_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┌annotationsrfZcreate_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_eventr\Zsoft_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_lossZconcurrencyZconsumerrbZdisable_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_keysSsrycs6ИjrЗЗЗfddДИjDГSИИабИИИfgS)Ncs$g|]}|аИбабИИИfСqSr)r┌upper)rZoldkeyйrrrrr┌ Ys z_to_compat..)rrzrxrr{r┌ _to_compatWs ■r}ccsjt||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┌ lsrЗ)rДcCsi|]\}}}||jУqSrrЖ)r┌old_keyr~rrrrrЗpscCsi|]\}}}||УqSrrйrrИZnew_keyr~rrrrЗqscCsi|]\}}}||УqSrrrЙrrrrЗrscCsbddlm}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_settingsys¤rТ)┌maxsizecCs╠|аб}zt||абt||абГWStk r▓tабD]n\}}|аб|абkrjtd||ГYSt|tГr>z"t||аб||абГWYStk rкYq>Xq>YnXtd|абt|абГS)zFind setting by name.N)┌lowerr r┌KeyErrorrrАr)┌DEFAULTS)rСrr┌optsrrrr Дs" "r )N)rP))r:┌collectionsrr┌datetimerZcelery.utils.functionalrZcelery.utils.serializationr┌__all__ZDEFAULT_POOLZDEFAULT_ACCEPT_CONTENT┌stripZDEFAULT_PROCESS_LOG_FMTZDEFAULT_TASK_LOG_FMTZDEFAULT_SECURITY_DIGESTZOLD_NSZOLD_NS_BEATZ OLD_NS_WORKERr rrrr&rryr}r rЦr@Z__compatZ _OLD_DEFAULTSZ_TO_OLD_KEYZ_TO_NEW_KEYr>┌keysZSETTING_KEYSZ_OLD_SETTING_KEYSrТr rrrr┌sЖ ∙ ь № Ў· ∙ ¤ ¤ ■¤ √ ∙ є■■ ш · · ў ¤√ ╨2 ╓АЮ