ó
P'—^c        
   @@  s  d  Z  d d l m Z d d l Z d d l m Z m Z d d l m Z d d l	 m
 Z
 d d l m Z d d l m Z d	 d
 d d g Z e j j d ƒ Z e e d ƒ Z d Z e rÀ d Z n. e rî e j d d !d× k  rå d Z qî d Z n  d d d d g Z d j ƒ  Z d Z d Z i d d 6d d 6d  d! 6Z i d d 6d d 6d" d! 6Z e d# dØ ƒ Z e j dÙ k  rue Z n  d	 e  f d) „  ƒ  YZ! i	 i e! d d& d* ƒd+ 6e! d, d& d- ƒd. 6e! e# d& d/ ƒd0 6e! d1 d& d2 ƒd3 6e! d d& d* ƒd4 6e! d d& d2 ƒd5 6e! d6 d& d2 ƒd7 6e! d d& d* ƒd8 6e! d9 d& d2 ƒd: 6e! e$ d& d/ ƒd; 6e! d& d* ƒ d< 6e! i  d& d= ƒd> 6e! d& d* e  d? 6e! d& d2 e  d@ 6e! d& d* e  dA 6e! d& d* e  dB 6e! d& d* e  dC 6dD 6i e! d& d* ƒ dE 6e! e$ d& d/ ƒdF 6e! d& d* ƒ dG 6e! d& d* ƒ dH 6e! d& dI ƒ dJ 6e! d& d* ƒ dK 6dL 6i@ e! e d& dI ƒdM 6e! e$ d& d/ ƒdN 6e! e$ d& d/ ƒdO 6e! d& dP ƒ dQ 6e! dR ƒ dS 6e! dR ƒ dT 6e! dU ƒ dV 6e! ƒ  dW 6e! i  d& d= ƒdX 6e! e# d& d/ ƒdY 6e! d d& d= ƒdZ 6e! e# d& d/ ƒd[ 6e! d& d* ƒ d\ 6e! e$ d& d/ ƒd] 6e! d^ ƒ d_ 6e! d^ ƒ d` 6e! d^ ƒ da 6e! db ƒ dc 6e! d' d& d* ƒdd 6e! e$ d& d/ ƒde 6e! e# d& d/ ƒdf 6e! e# d& d/ ƒdg 6e! d ƒ dh 6e! d d& d- ƒdi 6e! d d& d- ƒdj 6e! dÚ d& dk ƒdl 6e! dÛ d& dk ƒdm 6e! e$ d& d/ ƒdn 6e! d1 d& d2 ƒdo 6e! d& d* ƒ dp 6e! d& d= ƒ dq 6e! d& d* e  dr 6e! d& d2 e  ds 6e! d& d2 e  dt 6e! d& d* e  du 6e! d& d2 ƒ dv 6e! d& d* ƒ dw 6e! e$ d& d/ ƒdx 6e! d& d= ƒ dy 6e! ƒ  dz 6e! d& d= ƒ d{ 6e! d| ƒ d} 6e! db ƒ d~ 6e! d ƒ d 6e! d d& d/ ƒd€ 6e! d& dP ƒ d 6e! e$ d& d/ ƒd‚ 6e! e$ d& d/ ƒdƒ 6e! e$ d& d/ ƒd„ 6e! e$ d& d/ ƒd… 6e! e# d& d/ ƒd† 6e! i d d‡ 6d dˆ 6d d‰ 6dŠ d‹ 6d& d= ƒdŒ 6e! e d d ƒ d& d- ƒdŽ 6e! d ƒ d 6e! d& d* ƒ d 6e! e$ d& d/ ƒd‘ 6e! e# d& d/ ƒd’ 6e! d“ ƒ d” 6e! d& d= ƒ d• 6e! d d& d* ƒd– 6e! d& d* ƒ d— 6e! d& d* ƒ d˜ 6e! d& d* ƒ d™ 6e! e$ d& d/ ƒdš 6d› 6i e! d d& d* ƒdœ 6e! d ƒ dž 6e! dŸ ƒ d  6e! d d& d2 ƒd¡ 6e! d& d* ƒ d¢ 6e! d£ d& d- ƒd¤ 6e! e$ d& d/ ƒd¥ 6e! e# d& d/ ƒd¦ 6e! d§ d& d* ƒd¨ 6e! e ƒ d© 6e! d& d/ ƒ dª 6e! d« d d¬ d d d! d­ ƒd® 6e! d d¬ d d d! d¯ ƒ d° 6e! d& d2 ƒ d± 6e! e ƒ d² 6e! e# d& d/ ƒd³ 6e! e$ d& d/ ƒd´ 6e! d, d& d2 ƒdµ 6e! ƒ  d¶ 6e! e ƒ d· 6e! d& d- ƒ d¸ 6e! d& d- ƒ d¹ 6e! dº d& d- ƒd» 6d¼ 6i e! i  d& d= ƒd½ 6e! d¾ ƒ d¿ 6e! dÀ ƒ dÁ 6e! d d& d2 ƒdÂ 6e! d d& d- ƒdÃ 6e! dÄ d d¬ d d d! d­ ƒd® 6e! d d¬ d d d! d¯ ƒ d° 6dÅ 6i e! dÄ d d¬ d d d! d­ ƒd® 6e! d d¬ d d d! d¯ ƒ d° 6e! e ƒ d© 6dÆ 6i e! dÇ ƒ d? 6e! dÈ d& d2 ƒd@ 6e! ƒ  dÉ 6e! ƒ  dÊ 6e! d' d& d- ƒdË 6e! e$ d& d/ ƒd; 6e! e$ d& d/ ƒdÌ 6dÍ 6e! dÎ ƒ dÏ 6e! dÜ d& dk ƒdÐ 6Z% dÑ dÒ „ Z& e' dÓ „  e& e% ƒ Dƒ ƒ Z( dÔ „  Z) e dÕ d ƒ d^ dÖ „ ƒ Z* d S(Ý   sa   
    celery.app.defaults
    ~~~~~~~~~~~~~~~~~~~

    Configuration introspection and defaults.

i    (   t   absolute_importN(   t   dequet
   namedtuple(   t	   timedelta(   t   items(   t	   strtobool(   t   memoizet   Optiont
   NAMESPACESt   flattent   findt   javat   pypy_version_infot   preforkt   threadsi   i   i   t   solot   jsont   picklet   msgpackt   yamls>   
    [%(asctime)s: %(levelname)s/%(processName)s] %(message)s
s(   [%(asctime)s: %(levelname)s] %(message)ssT   [%(asctime)s: %(levelname)s/%(processName)s] %(task_name)s[%(task_id)s]: %(message)ss   2.5t   deprecate_bys   4.0t	   remove_bys   BROKER_URL settingt   alts!   URL form of CELERY_RESULT_BACKENDt   searchresultt	   namespacet   keyt   typei   i   c           B@  sn   e  Z d Z d Z d Z e d  e d e d e	 d d „  d e
 d e d e ƒ Z d d „ Z d	 „  Z d
 „  Z RS(   t   stringt   intt   floatt   anyc         C@  s   |  S(   N(    (   t   v(    (    s5   /tmp/pip-unpacked-wheel-gV1wwp/celery/app/defaults.pyt   <lambda>;   t    t   boolt   dictt   tuplec         O@  sR   | |  _  | j d ƒ p d |  _ x* t | ƒ D] \ } } t |  | | ƒ q. Wd  S(   NR   R   (   t   defaultt   getR   R   t   setattr(   t   selfR%   t   argst   kwargst   attrt   value(    (    s5   /tmp/pip-unpacked-wheel-gV1wwp/celery/app/defaults.pyt   __init__>   s    	c         C@  s   |  j  |  j | ƒ S(   N(   t   typemapR   (   R(   R,   (    (    s5   /tmp/pip-unpacked-wheel-gV1wwp/celery/app/defaults.pyt	   to_pythonD   s    c         C@  s   d j  |  j |  j ƒ S(   Ns"   <Option: type->{0} default->{1!r}>(   t   formatR   R%   (   R(   (    (    s5   /tmp/pip-unpacked-wheel-gV1wwp/celery/app/defaults.pyt   __repr__G   s    N(   t   __name__t
   __module__t   NoneR   R   R   R#   t   strR   R   R   R$   R.   R-   R/   R1   (    (    (    s5   /tmp/pip-unpacked-wheel-gV1wwp/celery/app/defaults.pyR   7   s   !	R   t   URLi   R   t   CONNECTION_TIMEOUTR"   t   CONNECTION_RETRYid   R   t   CONNECTION_MAX_RETRIESt   FAILOVER_STRATEGYt	   HEARTBEATg      @t   HEARTBEAT_CHECKRATEt   LOGIN_METHODi
   t
   POOL_LIMITt   USE_SSLt	   TRANSPORTR#   t   TRANSPORT_OPTIONSt   HOSTt   PORTt   USERt   PASSWORDt   VHOSTt   BROKERt   COLUMN_FAMILYt   DETAILED_MODEt   KEYSPACEt   READ_CONSISTENCYt   listt   SERVERSt   WRITE_CONSISTENCYt	   CASSANDRAt   ACCEPT_CONTENTt	   ACKS_LATEt   ALWAYS_EAGERR   t   ANNOTATIONSt	   celeryctlt   BROADCAST_QUEUEt   BROADCAST_EXCHANGEt   fanoutt   BROADCAST_EXCHANGE_TYPEt   CACHE_BACKENDt   CACHE_BACKEND_OPTIONSt   CHORD_PROPAGATESt   COUCHBASE_BACKEND_SETTINGSt   CREATE_MISSING_QUEUESt   DEFAULT_RATE_LIMITt   DISABLE_RATE_LIMITSt   celeryt   DEFAULT_ROUTING_KEYt   DEFAULT_QUEUEt   DEFAULT_EXCHANGEt   directt   DEFAULT_EXCHANGE_TYPEt   DEFAULT_DELIVERY_MODEt   EAGER_PROPAGATES_EXCEPTIONSt
   ENABLE_UTCt   ENABLE_REMOTE_CONTROLt   EVENT_SERIALIZERt   EVENT_QUEUE_EXPIRESt   EVENT_QUEUE_TTLR$   t   IMPORTSt   INCLUDEt   IGNORE_RESULTt   MAX_CACHED_RESULTSt   MESSAGE_COMPRESSIONt   MONGODB_BACKEND_SETTINGSt
   REDIS_HOSTt
   REDIS_PORTt   REDIS_DBt   REDIS_PASSWORDt   REDIS_MAX_CONNECTIONSt   RESULT_BACKENDt   RESULT_DB_SHORT_LIVED_SESSIONSt   RESULT_DB_TABLENAMESt   RESULT_DBURIt   RESULT_ENGINE_OPTIONSt   celeryresultst   RESULT_EXCHANGEt   RESULT_EXCHANGE_TYPEt   RESULT_SERIALIZERt   RESULT_PERSISTENTt   ROUTESt   SEND_EVENTSt   SEND_TASK_ERROR_EMAILSt   SEND_TASK_SENT_EVENTt   STORE_ERRORS_EVEN_IF_IGNOREDt   TASK_PUBLISH_RETRYt   max_retriest   interval_startt   interval_maxgš™™™™™É?t   interval_stept   TASK_PUBLISH_RETRY_POLICYt   dayst   TASK_RESULT_EXPIRESt   TASK_SERIALIZERt   TIMEZONEt   TRACK_STARTEDt   REDIRECT_STDOUTSt   WARNINGt   REDIRECT_STDOUTS_LEVELt   QUEUESt   QUEUE_HA_POLICYt   SECURITY_KEYt   SECURITY_CERTIFICATEt   SECURITY_CERT_STOREt   WORKER_DIRECTt   CELERYt   AGENTs"   celery.worker.autoscale:Autoscalert
   AUTOSCALERs%   celery.worker.autoreload:Autoreloadert   AUTORELOADERt   CONCURRENCYt   TIMERg      ð?t   TIMER_PRECISIONt   FORCE_EXECVt   HIJACK_ROOT_LOGGERs   celery.worker.consumer:Consumert   CONSUMERt
   LOG_FORMATt	   LOG_COLORt   WARNs   2.4s   --loglevel argumentt	   LOG_LEVELs   --logfile argumentt   LOG_FILEt   MAX_TASKS_PER_CHILDt   POOLt   POOL_PUTLOCKSt   POOL_RESTARTSt   PREFETCH_MULTIPLIERt   STATE_DBt   TASK_LOG_FORMATt   TASK_SOFT_TIME_LIMITt   TASK_TIME_LIMITg      $@t   WORKER_LOST_WAITt   CELERYDt   SCHEDULEs   celery.beat:PersistentSchedulert	   SCHEDULERs   celerybeat-schedulet   SCHEDULE_FILENAMEt
   SYNC_EVERYt   MAX_LOOP_INTERVALt   INFOt
   CELERYBEATt	   CELERYMONt	   localhosti   t	   HOST_USERt   HOST_PASSWORDt   TIMEOUTt   USE_TLSt   EMAILs   celery@localhostt   SERVER_EMAILt   ADMINSR!   c         c@  s‘   t  | |  f g ƒ } xu | rŒ | j ƒ  \ } } xV t | ƒ D]H \ } } t | t ƒ rv | j | | d | f ƒ q= | | | f Vq= Wq Wd  S(   Nt   _(   R   t   popleftR   t
   isinstanceR#   t   append(   t   dt   nst   stackt   namet   spaceR   R,   (    (    s5   /tmp/pip-unpacked-wheel-gV1wwp/celery/app/defaults.pyR	   è   s    	c         c@  s$   |  ] \ } } | | j  f Vq d  S(   N(   R%   (   t   .0R   R,   (    (    s5   /tmp/pip-unpacked-wheel-gV1wwp/celery/app/defaults.pys	   <genexpr>ñ   s    c         C@  s   d d l  m } xx t t ƒ D]j \ } } | j s; | j r t |  | d  ƒ r | d d j | ƒ d | j d | j d d j | ƒ ƒ q q W|  S(	   Ni    (   t   warn_deprecatedt   descriptions   The {0!r} settingt   deprecationt   removalt   alternatives   Use the {0.alt} instead(	   t   celery.utilsRÏ   R	   R   R   R   t   getattrR4   R0   (   t   sourceRÏ   RÌ   t   opt(    (    s5   /tmp/pip-unpacked-wheel-gV1wwp/celery/app/defaults.pyt   find_deprecated_settingsô   s    $		t   maxsizec         C@  s÷   | j  ƒ  } y( t | |  j  ƒ  t | |  j  ƒ  ƒ SWn  t k
 rÖ x t t ƒ D]~ \ } } | j  ƒ  |  j  ƒ  k r… t d  | | ƒ St | t ƒ rQ y$ t | |  j  ƒ  | |  j  ƒ  ƒ SWqÏ t k
 rË qÏ XqQ qQ Wn Xt d  |  j  ƒ  t |  j  ƒ  ƒ S(   N(	   t   upperR   R   t   KeyErrorR   R4   RÇ   R#   t   DEFAULTS(   RÌ   R   RÊ   t   keys(    (    s5   /tmp/pip-unpacked-wheel-gV1wwp/celery/app/defaults.pyR
   ÿ   s    %$(   i   i   i    (   R   R   R   (   i   i   i   (    (    (    (+   t   __doc__t
   __future__R    t   syst   collectionsR   R   t   datetimeR   t   celery.fiveR   RÔ   R   t   celery.utils.functionalR   t   __all__t   platformt
   startswitht	   is_jythont   hasattrt   is_pypyt   DEFAULT_POOLR   t   DEFAULT_ACCEPT_CONTENTt   stript   DEFAULT_PROCESS_LOG_FMTt   DEFAULT_LOG_FMTt   DEFAULT_TASK_LOG_FMTt   _BROKER_OLDt
   _REDIS_OLDR   t   version_infot   objectR   R4   t   Truet   FalseR   R	   R#   RÜ   RØ   R
   (    (    (    s5   /tmp/pip-unpacked-wheel-gV1wwp/celery/app/defaults.pyt   <module>   sj  			

	









		