File: //home/arjun/projects/env/lib/python3.10/site-packages/celery/bin/__pycache__/shell.cpython-310.pyc
o
-we� �
@ s2 d Z ddlZddlZddlmZ ddlZddlmZmZm Z dd� Z
dd� Z d d
� Z d d � Z
d
d� Zdd� Zdd� Zdd� Zdd� Zejeddid�ejddded d d �ejd d ded d!d �ejd"ded d#d �ejd$d%ded d&d �ejd'ded d(d �ejd)ded d*d �eje + + +d.d,d-����������ZdS )/z3The ``celery shell`` program, used to start a REPL.� N)�
import_module)�
CeleryCommand� CeleryOption�handle_preload_optionsc C s\ dd l }zdd l}W n ty Y nw dd l}|�|�| �j� |�d� |j| d� d S )Nr z tab:complete)�local) �code�readline� ImportError� rlcompleter�
set_completer� Completer�complete�parse_and_bind�interact)�localsr r r
� r �I/home/arjun/projects/env/lib/python3.10/site-packages/celery/bin/shell.py�_invoke_fallback_shell s �
�
r c C s dd l }|�| � d S �Nr )�bpython�embed)r r r r r �_invoke_bpython_shell s r c C s8 t ttttfD ]}z|| �W S ty Y qw d S )N)�_ipython�_ipython_pre_10�_ipython_terminal� _ipython_010� _no_ipythonr )r �ipr r r �_invoke_ipython_shell s � ��r c C s ddl m} |g | d� d S )Nr )�
start_ipython��argv�user_ns)�IPythonr )r r r r r r ) s r c C s: ddl m} |�� }|jg d� |jj�| � |�� d S )Nr )�TerminalIPythonApp)r! )� IPython.frontend.terminal.ipappr$ �instance�
initialize�shellr" �update�start)r r$ �appr r r r . s
r c C s ddl m} |j| d��� d S )Nr )r )r" )�IPython.terminalr �TerminalInteractiveShell�mainloop)r r r r r r 6 � r c C s ddl m} |g | d��� d S )Nr )�IPShellr )�
IPython.Shellr0 r. )r r0 r r r r ; r/ r c C s t d��)Nzno suitable ipython found)r )�selfr r r r @ s r c C sb zdd l }W n$ ty* zdd l}W n ty" t| � Y Y d S w t| � Y d S w t| � d S r )r# r r r r r )r r# r r r r �_invoke_default_shellD s �� r3 �allow_extra_argsT)�cls�context_settingsz-Iz --ipythonz
Shell OptionszForce IPython.)�is_flagr5 �
help_group�helpz-Bz --bpythonzForce bpython.z--pythonzForce default Python shell.z-Tz--without-taskszDon't add tasks to locals.z
--eventletz
Use eventlet.z--geventz Use gevent.Fc K s4 t j�dt�� � |rtd� |rtd� ddl}| jj} | j �
� | | |j |j |j
|j|j|j|j|j|jd� }
|sH|
�dd� | j�� D �� |rOt|
� nE|rlzt|
� W n< tyk | j�| jj� d�� Y n)w |r�zt |
� W n ty� } z| j�| jj� d | � �� W Y d} ~ nd} ~ ww t |
� dS )
a. Start shell session with convenient access to celery symbols.
The following symbols will be added to the main globals:
- ``celery``: the current application.
- ``chord``, ``group``, ``chain``, ``chunks``,
``xmap``, ``xstarmap`` ``subtask``, ``Task``
- all registered tasks.
r zcelery.concurrency.eventletzcelery.concurrency.geventN) r+ �celery�Task�chord�group�chain�chunks�xmap�xstarmap�subtask� signaturec S s i | ] }|j �d �s|j|�qS )zcelery.)�name�
startswith�__name__)�.0�taskr r r �
<dictcomp>� s
��zshell.<locals>.<dictcomp>z: bpython is not installedz: ) �sys�path�insert�os�getcwdr r: �objr+ �loader�import_default_modulesr; r< r= r> r? r@ rA rB rC r) �tasks�valuesr r r �echo�ERRORr r3 ) �ctx�ipythonr �python�
without_tasks�eventlet�gevent�kwargsr: r+ r �er r r r( R sP 1
�
�
� &�� r( )FFFFFF)�__doc__rM rJ � importlibr �click�celery.bin.baser r r r r r r r r r r r3 �command�option� pass_contextr( r r r r �<module> s~
������� �