U
    .e                     @   s  d Z ddlZddlZddlZddlZzddlmZ W n  ek
rT   ddlmZ Y nX ddl	Z	ddl
Z	ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd	lmZ dd
lmZmZmZ ddlmZ ddlmZ ddlm Z 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l+m,Z, ddl-m.Z. ddl/m0Z0 ddl1m2Z2 ddl3m4Z4 ddl5m6Z6 ddl7m8Z8 e	j9dddZ:e	j9dddZ;e	9dZ<G dd deZ=e= Z>ej?d kred!d"Z@n8ze Ad!g Z@W n$ eBk
r   e jCd!d"Z@Y nX ee@e	jDed#d$e	jEd%d&d'ee>d(d)e	jEd*d+d,ed(d-e	jEd.d/ed(d-e	jEd0d1ed(d-e	jEd2d3ed(d-e	jEd4eejFd5d6 d#d(d7e	jEd8d9d:d#ed(d;e	jEd<d=d#ed(d>e	jEd?ed#d(d@e	jEdAdBed#d(dCdDe	jGdEdF ZejHedGe	jGdHdI ZIeJe0 eJe eJe eJe( eJe2 eJe, eJe" eJe8 eJe$ eJe! eJe  eJe& eJe6 eJe* eJe eJe4 eJe. e	jKjLjMZNdJZOdPdKdLZPePe	jKjL_MeQdMdNdOZRdS )QzCelery Command Line Interface.    N)entry_points)	ParamType)DYMGroup)with_plugins)VERSION_BANNER)find_app)amqp)CeleryCommandCeleryOption
CLIContext)beat)call)controlinspectstatus)events)graph)list_)logtool)migrate)multi)purge)result)shell)upgrade)workerzA
Unable to load celery application.
The module {0} was not found.redZfgzi
Unable to load celery application.
While trying to load the module {0} the following error occurred:
{1}z'
Unable to load celery application.
{0}c                   @   s   e Zd ZdZdZdd ZdS )AppzApplication option.Zapplicationc              
   C   s   z
t |W S  tk
rb } z:|j|kr@t }| t|| | t|j W 5 d }~X Y nl t	k
r } z"|j
d  }| t| W 5 d }~X Y n. tk
r   t }| t|| Y nX d S )Nr   )r   ModuleNotFoundErrorname	traceback
format_excZfail!UNABLE_TO_LOAD_APP_ERROR_OCCURREDformat#UNABLE_TO_LOAD_APP_MODULE_NOT_FOUNDAttributeErrorargs
capitalizeUNABLE_TO_LOAD_APP_APP_MISSING	Exception)selfvalueparamctxeexcZattribute_name r1   5/tmp/pip-unpacked-wheel-f4liivr4/celery/bin/celery.pyconvert8   s"    


" 
zApp.convertN)__name__
__module____qualname____doc__r    r3   r1   r1   r1   r2   r   3   s   r   )   
   zcelery.commands)groupT)clsZinvoke_without_command-A--appAPPzGlobal Options)envvarr;   type
help_groupz-bz--brokerZ
BROKER_URL)r?   r;   rA   z--result-backendZRESULT_BACKENDz--loaderZLOADERz--configZCONFIG_MODULEz	--workdirc                 C   s   |rt |S d S )N)oschdir)___wdr1   r1   r2   <lambda>t       rG   )r;   r@   callbackZis_eagerrA   z-Cz
--no-colorZNO_COLOR)r?   is_flagr;   rA   z-qz--quiet)rJ   r;   rA   z	--version)r;   rJ   rA   z--skip-checksZSKIP_CHECKSzSkip Django core checks on startup. Setting the SKIP_CHECKS environment variable to any non-empty string will have the same effect.)r?   r;   rJ   rA   helpc                 C   s  |	rt t |   n | jdkr8t |   |   |rF|tjd< |rT|tjd< |rb|tjd< |rp|tjd< |
r~dtjd< t||||d| _	t
j| j	jjd	g  tj| j	jjd
g  tj| j	jjdg  tj D ]}|j| j	jjdg  qdS )zCelery command entrypoint.NZCELERY_LOADERZCELERY_BROKER_URLZCELERY_RESULT_BACKENDZCELERY_CONFIG_MODULEtrueZCELERY_SKIP_CHECKS)appno_colorworkdirquietr   r   r   Zpreload)clickechor   exitZinvoked_subcommandZget_helprB   environr   objr   paramsextendrM   user_optionsgetr   r   celerycommandsvalues)r.   rM   ZbrokerZresult_backendloaderconfigrO   rN   rP   versionZskip_checkscommandr1   r1   r2   rZ   X   s0    9







rZ   )r;   c                 K   s&   | j j}|j  | j |  dS )z3Shows information useful to include in bug-reports.N)rU   rM   r]   Zimport_default_modulesrR   Z	bugreport)r.   kwargsrM   r1   r1   r2   report   s    
rb   a  You are using `{option_name}` as an option of the {info_name} sub-command:
celery {info_name} {option_name} celeryapp <...>

The support for this usage was removed in Celery 5.0. Instead you should use `{option_name}` as a global option:
celery {option_name} celeryapp {info_name} <...>c                 C   s<   | j dkr,| jjjtj| j | jjddd t| |d d S )N)r<   r=   )option_name	info_namer   r   )file)rc   r.   rU   errorWRONG_APP_OPTION_USAGE_MESSAGEr$   rd   previous_show_implementation)r+   re   r1   r1   r2   _show   s    
ri   )returnc                   C   s
   t ddS )zStart celery umbrella command.

    This function is the main entrypoint for the CLI.

    :return: The exit code of the CLI.
    ZCELERY)Zauto_envvar_prefix)rZ   r1   r1   r1   r2   main   s    rk   )N)Sr7   rB   pathlibsysr!   importlib.metadatar   ImportErrorZimportlib_metadatarQ   Zclick.exceptionsZclick.typesr   Zclick_didyoumeanr   Zclick_pluginsr   rZ   r   Zcelery.app.utilsr   Zcelery.bin.amqpr   Zcelery.bin.baser	   r
   r   Zcelery.bin.beatr   Zcelery.bin.callr   Zcelery.bin.controlr   r   r   Zcelery.bin.eventsr   Zcelery.bin.graphr   Zcelery.bin.listr   Zcelery.bin.logtoolr   Zcelery.bin.migrater   Zcelery.bin.multir   Zcelery.bin.purger   Zcelery.bin.resultr   Zcelery.bin.shellr   Zcelery.bin.upgrader   Zcelery.bin.workerr   styler%   r#   r)   r   r>   version_infoZ_PLUGINSrY   r&   selectr:   optionPathZpass_contextr`   rb   Zadd_command
exceptionsZNoSuchOptionshowrh   rg   ri   intrk   r1   r1   r1   r2   <module>   s  
"!




















