Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/celery/bin/__pycache__/ |
a
��Sh� � @ s, 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 }z dd l}W n ty& Y n&0 dd l}|�|�| �j� |�d� |j| d� d S )Nr z tab:complete)�local) �code�readline� ImportError� rlcompleterZ
set_completerZ CompleterZcomplete�parse_and_bindZinteract)�localsr r r
� r
�:/usr/local/lib/python3.9/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 s: t ttttfD ]&}z|| �W S ty2 Y q0 qd 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 )Z IPython.frontend.terminal.ipappr �instanceZ
initialize�shellr �update�start)r r �appr
r
r r . s
r c C s ddl m} |j| d��� d S )Nr )r )r )ZIPython.terminalr ZTerminalInteractiveShell�mainloop)r r r
r
r r 6 s r c C s ddl m} |g | d��� d S )Nr )�IPShellr )Z
IPython.Shellr' r& )r r' r
r
r r ; s r c C s t d��d S )Nzno suitable ipython found)r )�selfr
r
r r @ s r c C s\ z dd l }W nB tyN z dd l}W n ty@ t| � Y n
0 t| � Y n
0 t| � d S r )r r r r r r )r r r r
r
r �_invoke_default_shellD s r) Zallow_extra_argsT)�clsZcontext_settingsz-Iz --ipythonz
Shell OptionszForce IPython.)Zis_flagr* Z
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 s: t j�dt�� � |r td� |r*td� ddl}| jj} | j �
� | | |j |j |j
|j|j|j|j|j|jd� }
|s�|
�dd� | j�� D �� |r�t|
� n�|r�z t|
� W n( ty� | j�| jj� d�� Y n0 nT|�r.z t |
� W n@ t�y, } z&| j�| jj� d | � �� W Y d} ~ n
d} ~ 0 0 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% �loaderZimport_default_modulesr- r. r/ r0 r1 r2 r3 r4 r5 r# �tasks�valuesr r r Zecho�ERRORr r) ) �ctxZipythonr �pythonZ
without_tasksZeventletZgevent�kwargsr, r% r �er
r
r r" R sJ 1
�
�
0r" )FFFFFF)�__doc__r? r< � importlibr ZclickZcelery.bin.baser r r r r r r r r r r r) �command�optionZ pass_contextr" r
r
r
r �<module> s|
������� �