File: //home/arjun/projects/env/lib64/python3.10/site-packages/flower/__pycache__/command.cpython-310.pyc
o
/we� � @ sP d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dlZd dl m
Z
d dl m Z m Z d dl
mZ d dlmZ dd lmZ dd
lmZ dd lmZmZmZ dd l
mZmZ dd
lm Z e� e �Z dZ dd� Z!ej"eddid�ej#ddej$d�ej%dd� ���Z&dd� Z'dd � Z(d d � Z)d d � Z*d!d"� Z+d#d$� Z,d%d&� Z-d'd(� Z.dS ))� N)�pformat)� NullHandler)�options)�parse_command_line�parse_config_file)�enable_pretty_logging)�
CeleryCommand� )�Flower)�settings)�abs_path� prepend_url� strtobool)�DEFAULT_CONFIG_FILE�default_options)�validate_auth_option�FLOWER_c C s t �d| � t�d� d S )Nz%s detected, shutting downr )�logger�info�sys�exit)�signum�_� r �G/home/arjun/projects/env/lib/python3.10/site-packages/flower/command.py�sigterm_handler s r �ignore_unknown_optionsT)�cls�context_settings� tornado_argv���)�nargs�typec C s� t | |� t� ttjd |� t� t� | jj}t d|t
d�t ��}t �
|j� t�tjt� | jjs<t|dt v � z|�� W dS ttfyO Y dS w )zAWeb based tool for monitoring and administrating Celery clusters.r )�cappr � ssl_optionsNr )�-warn_about_celery_args_used_in_flower_command�apply_env_options�
apply_optionsr �argv�extract_settings�
setup_logging�obj�appr
r r �atexit�register�stop�signal�SIGTERMr �quiet� print_banner�start�KeyboardInterrupt�
SystemExit)�ctxr r, �
flower_appr r r �flower s
�r9 c s� t ttj�} | D ]Q}|�tdd��� }tj| }ztj| � W n t y1 tj|�dd� � Y nw � j
rB� fdd�|� d�D �}n� j t
u rNt
t|��}n� � |�}tt||� qdS ) z2apply options passed through environment variables� r r �-c s g | ]}� � |��qS r )r" )�.0�i��optionr r �
<listcomp>I s z%apply_env_options.<locals>.<listcomp>�,N)�filter�is_flower_envvar�os�environ�replace�ENV_VAR_PREFIX�lowerr �_options�KeyError�multiple�splitr" �boolr �setattr)� env_options� env_var_name�name�valuer r> r r& > s
�
�r& c C sp t tt|��}t| g| � zttj�tj �dd� t| g| � W dS t
y7 tj� tj �t kr4� Y dS w )z3apply options passed through the configuration fileF)�finalN)
�listrB �is_flower_optionr r rD �path�abspathr �conf�IOError�basenamer )� prog_namer( r r r r' R s ��r' c C s\ dd� | j jjD �}g }|D ]}|�d�\}}}||v r!|�|� q|r,t�d|� d S d S )Nc S s g | ]
}|j D ]}|�qqS r )�opts)r< �paramr? r r r r@ ` s zAwarn_about_celery_args_used_in_flower_command.<locals>.<listcomp>�=z�You have incorrectly specified the following celery arguments after flower command: %s. Please specify them after celery command instead following this template: celery [celery args] flower [flower args].)�parent�command�params� partition�appendr �warning)r7 � flower_args�celery_options�incorrectly_used_args�arg�arg_namer r r r r% _ s
���r% c C sB t jrt jdkrdt _t� d S t�d��t� � dt�d�_d S )Nr �debugztornado.accessF)r rj �loggingr � getLogger�
addHandlerr � propagater r r r r* q s
r* c C s� t jtd< t jr
t jtd< t jr dD ] } tt| t j�t| < qt jr?t jp*tj �
d�t j p2tj �
d�t j p:tj �
d�d�td< t j
r_t jr_ttt j
�tt j�d �td
< t jr_tt j�td
d < t jrutt j�swt�d t j� t�d
� d S d S d S )Nrj �
cookie_secret)� login_url�static_url_prefix�FLOWER_OAUTH2_KEY�FLOWER_OAUTH2_SECRET�FLOWER_OAUTH2_REDIRECT_URI)�key�secret� redirect_uri�oauth)�certfile�keyfiler$ �ca_certszInvalid '--auth' option: %sr )r rj r ro �
url_prefixr
�auth�
oauth2_keyrD rE �get�
oauth2_secret�oauth2_redirect_uriry rz �dictr r{ r r �errorr r �rQ r r r r) z s*
�
��r) c C s, | � d��d�\}}}|�dd�}tt|�S )Nr; r^ r )�lstriprb rF �hasattrr )rh rQ r r r r rU � s
rU c C s" | � t�o| tt�d � �� tv S )N)�
startswithrG �lenrH r r� r r r rC � s
�rC c C s� t js"t jrdt j� d�}nd}t�d|rdndt jp dt j|� nt�dt j� t�d| �� �� � t�dt t
| j � � ��� t�
d t t�� d S )
N�/r: z Visit me at http%s://%s:%s%s�sz0.0.0.0z!Visit me via unix socket file: %sz
Broker: %szRegistered tasks:
%sz Settings: %s)r � unix_socketr| r r �address�port�
connection�as_urir �sorted�tasks�keysrj r )r, �ssl�
prefix_strr r r r3 � s ��r3 )/rD r r- r0 rk �pprintr r �click�tornado.optionsr r r � tornado.logr �celery.bin.baser r, r
�urlsr �utilsr r
r r r �
views.authr rl �__name__r rG r r` �argument� UNPROCESSED� pass_contextr9 r& r' r% r* r) rU rC r3 r r r r �<module> sF
��