o h @s2dZddlZddlZddlmZddlZddlmZmZm Z ddZ ddZ d d Z d d Z d dZddZddZddZddZejeddidejdddedddejdd dedd!dejd"dedd#dejd$d%dedd&dejd'dedd(dejd)dedd*deje + + +d.d,d-ZdS)/z3The ``celery shell`` program, used to start a REPL.N) import_module) CeleryCommand CeleryOptionhandle_preload_optionscCs\ddl}zddl}Wn tyYnwddl}|||j|d|j|ddS)Nrz tab:complete)local) codereadline ImportError rlcompleter set_completer Completercompleteparse_and_bindinteract)localsrrr rB/var/www/html/env/lib/python3.10/site-packages/celery/bin/shell.py_invoke_fallback_shell s    rcCsddl}||dSNr)bpythonembed)rrrrr_invoke_bpython_shellsrc Cs8tttttfD]}z||WStyYqwdS)N)_ipython_ipython_pre_10_ipython_terminal _ipython_010 _no_ipythonr )riprrr_invoke_ipython_shells rcCsddlm}|g|ddS)Nr) start_ipythonargvuser_ns)IPythonr)rrrrrr)s rcCs:ddlm}|}|jgd|jj||dS)Nr)TerminalIPythonApp)r!)IPython.frontend.terminal.ipappr$instance initializeshellr"updatestart)rr$apprrrr.s   rcCs ddlm}|j|ddS)Nr)r)r")IPython.terminalrTerminalInteractiveShellmainloop)rrrrrr6 rcCs ddlm}|g|ddS)Nr)IPShellr ) IPython.Shellr0r.)rr0rrrr;r/rcCstd)Nzno suitable ipython found)r )selfrrrr@src Csbzddl}Wn$ty*zddl}Wnty"t|YYdSwt|YdSwt|dSr)r#r rrrr)rr#rrrr_invoke_default_shellDs     r3allow_extra_argsT)clscontext_settingsz-Iz --ipythonz Shell OptionszForce IPython.)is_flagr5 help_grouphelpz-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 Ks4tjdt|rtd|rtdddl}|jj} | j | | |j |j |j |j|j|j|j|j|jd } |sH| dd| jD|rOt| nE|rlzt| Wn<tyk|j|jjdYn)w|rzt| Wnty} z|j|jjd | WYd} ~ nd} ~ wwt| 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. rzcelery.concurrency.eventletzcelery.concurrency.geventN) r+celeryTaskchordgroupchainchunksxmapxstarmapsubtask signaturecSs i|] }|jds|j|qS)zcelery.)name startswith__name__).0taskrrr s  zshell..z: bpython is not installedz: )syspathinsertosgetcwdrr:objr+loaderimport_default_modulesr;r<r=r>r?r@rArBrCr)tasksvaluesrrr echoERRORrr3) ctxipythonrpython without_taskseventletgeventkwargsr:r+rerrrr(RsP1      & r()FFFFFF)__doc__rMrJ importlibrclickcelery.bin.baserrrrrrrrrrrr3commandoption pass_contextr(rrrrs~