File: //home/arjun/projects/env/lib/python3.10/site-packages/flower/__pycache__/app.cpython-310.pyc
o
/we�
� @ s� d dl Z d dlZd dlmZ d dlZd dlZd dlmZ d dlm Z d dlm
Z
ddl m Z
ddlmZ dd lmZ dd
lmZ e�e�Ze jd d krde jd d krde j�d
�rdd dlZe�e� � � dd� Z G dd� dej j �Z dS )� N)�ThreadPoolExecutor)�ioloop)�
HTTPServer)�url� ��handlers)�Events)� Inspector)�default_options� � �winc C sN t | t�rtd�|�d�| jj�| j| j| j�S d�|�d�| d �| d fS )Nz/{}{}�/r r ) �
isinstancer �format�strip�regex�pattern�
handler_class�kwargs�name)�handler�
url_prefix� r �C/home/arjun/projects/env/lib/python3.10/site-packages/flower/app.py�rewrite_handler s
� r c s\ e Zd ZeZdZ d� fdd� Zdd� Zdd� Ze dd � �Z
e d
d � �Z dd d
�Z � Z
S )�FlowerNc
s t }� d ur� jr� fdd�|D �}|j|d� t� jd i |�� � p$t| _|p,tj� � | _
|� dd �| _ |p:t
�� | _| jj�� | j| jd�| _| j
�| j� t| j
| j| jjd �| _|pyt| j| jj| jj| jj | jj | j
| jj| jj d�| _ d| _ d S )
Nc s g | ]}t |� j��qS r )r r )�.0�h��optionsr r �
<listcomp>* s z#Flower.__init__.<locals>.<listcomp>r � ssl_options)� max_workersg @�@)�db�
persistent�state_save_interval�
enable_events�io_loop�max_workers_in_memory�max_tasks_in_memoryFr )!�default_handlersr �update�super�__init__r r! r �IOLoop�instancer) �getr# �celery�Celery�capp�loader�import_default_modules�pool_executor_clsr$ �executor�set_default_executorr
�inspect_timeout� inspectorr r% r& r' r( � max_tasks�events�started)�selfr! r5 r> r) r r �� __class__r r r/ & s0
�
zFlower.__init__c C s~ | j �� | jjs| j| jj| jj| j| jjd� nddl m
} t | �}|| jjdd�}|� |� d| _
| �� | j�� d S )N)�addressr# �xheadersr )�bind_unix_socketi� )�modeT)r> �startr! � unix_socket�listen�portrC r# rD �tornado.netutilrE r �
add_socketr? �update_workersr) )r@ rE �server�socketr r r rG D s
�
z Flower.startc C sJ | j r#| j�� t�d� | jjdd� t�d� | j�� d| _ d S d S )NzStopping executors...F)�waitzStopping event loop...)r? r> �stop�logging�debugr9 �shutdownr) �r@ r r r rQ U s
�z Flower.stopc C s t | j�� jdd �S )N� driver_type)�getattrr5 �
connection� transportrU r r r rY ^ s zFlower.transportc C s | j jS �N)r< �workersrU r r r r[ b s zFlower.workersc C s | j �|�S rZ )r< �inspect)r@ �
workernamer r r rM f s zFlower.update_workers)NNNNrZ )�__name__�
__module__� __qualname__r r8 r$ r/ rG rQ �propertyrY r[ rM �
__classcell__r r rA r r " s �
r )!�sysrR �concurrent.futuresr r3 � tornado.web�tornador �tornado.httpserverr r �urlsr r, r> r r< r
r! r � getLoggerr^ �logger� version_info�platform�
startswith�asyncio�set_event_loop_policy� WindowsSelectorEventLoopPolicyr �web� Applicationr r r r r �<module> s$
(