ó j4Vdc@€sšddlmZddlmZddlZddlZddlZddlmZddl m Z m Z m Z ddl mZmZmZddlmZddlmZdd lmZmZmZdd lmZejd dkr"d efd„ƒYZd„Zeje_ ee_nd„Z!d„Z"defd„ƒYZ#de#fd„ƒYZ$d„Z%d„Z&d„Z'd„Z(d„Z)d„Z*dS(iÿÿÿÿ(twith_statement(twrapsN(tstate(taborttwarnterror(tto_dicttnormalize_to_stringtdisconnect_all(tsettings(tJobQueue(tcrawltmerget parse_kwargs(t NetworkErroriitArgSpeccB€seZd„Zd„ZRS(cC€s=||_||_||_||_||||f|_dS(N(targstvarargstkeywordstdefaultst_tuple(tselfRRRR((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyt__init__s     cC€s |j|S(N(R(Rtidx((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyt __getitem__s(t__name__t __module__RR(((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyRs cC€sttj|ƒŒS(N(Rtinspectt _getargspec(tfunc((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pytpatched_get_argspecsc C€sÙ|jrtj|jƒndg}tj|ƒ}|jsBgn|j}t|ƒ}|jt|jƒ| }|jd|}|jddj |gt ||ƒD]\}}d||f^q¤ƒƒdj |ƒS(NsNo docstring providediÿÿÿÿs Arguments: %ss, s%s=%rs ( t__doc__ttextwraptdedentRt getargspecRtlenRtappendtjointzip( ttasktdetailstargspect default_argstnum_default_argstargs_without_defaultstargs_with_defaultstargtdefault((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pytget_task_details%s   5c€s‡fd†}|S(Nc€sˆj|gƒS(N(tget(tkey(tenv(sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pytinner=s((R3R4((R3sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyt _get_list<stTaskcB€sbeZdZdZeZdZeZ ddedd„Z d„Z d„Z dd„Z d„ZRS(s˜ Abstract base class for objects wishing to be picked up as Fabric tasks. Instances of subclasses will be treated as valid tasks when present in fabfiles loaded by the :doc:`fab ` tool. For details on how to implement and use `~fabric.tasks.Task` subclasses, please see the usage documentation on :ref:`new-style tasks `. .. versionadded:: 1.1 t undefinedcO€sX|dk r|g|_n|dk r3||_n|dk rK||_n||_dS(N(tNonetaliasestnamet is_default(RtaliasR9R/R:Rtkwargs((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyRUs     cC€s t|jƒS(N(R0trun(R((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyt __details___scC€s t‚dS(N(tNotImplementedError(R((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyR>bsc C€så|pigd6gd6gd6}|jdiƒ}|s?|rXt||||ƒ|fSt|dgƒ}t|dgƒ}|sˆ|r¡t||||ƒ|fStt|ƒdjƒƒ}|j|ƒt|Œ|jdgƒfS(sø Return a tuple containing the host list the given task should be using and the roles being used. See :ref:`host-lists` for detailed documentation on how host lists are set. .. versionchanged:: 1.9 thoststrolest exclude_hoststroledefsshosts roles exclude_hosts(R1R tgetattrtmapR5tsplitR$( Rt arg_hostst arg_rolestarg_exclude_hostsR3RDt func_hostst func_rolestenv_vars((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pytget_hosts_and_effective_roleses !   cC€sj|pt|ƒ}t|ddƒ}t|p0|ƒ}t|t|ƒfƒ}tjjrfd|GHn|S(Nt pool_sizes(Parallel tasks now using pool size of %d(R#RER8tinttminRtoutputtdebug(RRAR/tdefault_pool_sizet from_taskRO((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyt get_pool_sizes  N(RRRR:tTruetuse_task_objectsR8R9tFalseR;RR?R>RNRV(((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyR6Bs    tWrappedCallableTaskcB€s;eZdZd„Zd„Zd„Zd„Zd„ZRS(sù Wraps a given callable transparently, while marking it as a valid Task. Generally used via `~fabric.decorators.task` and not directly. .. versionadded:: 1.1 .. seealso:: `~fabric.docs.unwrap_tasks`, `~fabric.decorators.task` cO€s¥tt|ƒj||Ž||_t|dƒre|jdkrV|j|_|_qe|j|_nt|dƒrƒ|j|_nt|dƒr¡|j|_ndS(NRR7RR( tsuperRZRtwrappedthasattrR:RRR(RtcallableRR=((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyR›s cO€s|j||ŽS(N(R>(RRR=((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyt__call__ªscO€s|j||ŽS(N(R\(RRR=((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyR>­scC€st|j|ƒS(N(RER\(Rtk((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyt __getattr__°scC€s8|}x%d|jkr-|jjdƒ}q Wt|ƒS(NR\(t__dict__R1R0(Rtorig((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyR?³s(RRRRR_R>RaR?(((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyRZ‘s      cC€s/tjjrt|dtƒ p.t|dtƒS(s Returns True if given ``task`` should be run in parallel mode. Specifically: * It's been explicitly marked with ``@parallel``, or: * It's *not* been explicitly marked with ``@serial`` *and* the global parallel option (``env.parallel``) is set to ``True``. tserialtparallel(RR3ReRERY(R'((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pytrequires_parallelºs cC€sttd„|ƒƒS(NcS€stt|dtjƒƒS(Ni(RfR Rtcommands(tx((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pytÌt(tanyRF(tcommands_to_run((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyt_parallel_tasksÊscC€stjjd otjjS(Ntnetwork(RR3tuse_exceptions_fortskip_bad_hosts(((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyt_is_network_error_ignoredÑsc €stjjr2tˆdƒ r2d||dfGHnt|ƒ}|j|ƒ|dk ru|jitd6td6ƒn|dk rô|d} ‡fd†} i|d6|d 6|d 6| d 6|d 6} |jd | d | ƒ} | | _ |j | ƒn#t |ˆj ||ŽSWdQXdS(s4 Primary single-host work body of execute() t return_values[%s] Executing task '%s'tcommandRetlinewiset host_stringc€sÌtjj|ƒ‡‡fd†}y'tjjƒ|ˆj||ŽƒWn|tk rÇ}|jtk r¦t |t ƒot ƒs™t j jdˆƒn||ƒnt |t ƒo»t ƒsÈ‚qÈnXdS(Nc€sˆjiˆd6|d6ƒdS(NR:tresult(tput(Rv(R:tqueue(sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pytsubmitîss0!!! Parallel execution exception under host %r: (RR3tupdatet connectionstclearR>t BaseExceptiont __class__t SystemExitt isinstanceRRqtsyststderrtwrite(RR=RxR:R3Ryte(R'(R:RxsZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyR4ìs    RR=RxR:R3ttargetN( RRRtrunningR]RRzR8RWtProcessR:R$R R>( R'thosttmy_envRR=tjobsRxtmultiprocessingt local_envR:R4t kwarg_dicttp((R'sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyt_executeÕs(        cC€s t|tƒS(N(R€R6(R'((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyt_is_tasksc O€s»itd6}i}t|ƒ}|p.t|ƒs||d`, e.g. ``"deploy.migrate"``. The task will then be executed once per host in its host list, which is (again) assembled in the same manner as CLI-specified tasks: drawing from :option:`-H`, :ref:`env.hosts `, the `~fabric.decorators.hosts` or `~fabric.decorators.roles` decorators, and so forth. ``host``, ``hosts``, ``role``, ``roles`` and ``exclude_hosts`` kwargs will be stripped out of the final call, and used to set the task's host list, as if they had been specified on the command line like e.g. ``fab taskname:host=hostname``. Any other arguments or keyword arguments will be passed verbatim into ``task`` (the function itself -- not the ``@task`` decorator wrapping your function!) when it is called, so ``execute(mytask, 'arg1', kwarg1='value')`` will (once per host) invoke ``mytask('arg1', kwarg1='value')``. :returns: a dictionary mapping host strings to the given task's return value for that host's execution run. For example, ``execute(foo, hosts=['a', 'b'])`` might return ``{'a': None, 'b': 'bar'}`` if ``foo`` returned nothing on host `a` but returned ``'bar'`` on host `b`. In situations where a task execution fails for a given host but overall progress does not abort (such as when :ref:`env.skip_bad_hosts ` is True) the return value for that host will be the error object or message. .. seealso:: :ref:`The execute usage docs `, for an expanded explanation and some examples. .. versionadded:: 1.3 .. versionchanged:: 1.4 Added the return value mapping; previously this function had no defined return value. t clean_revertRss'%r is not callable or a valid task nametskip_unknown_tasksNRR:t all_hoststeffective_rolesiÿÿÿÿsÙ At least one task needs to be run in parallel, but the multiprocessing module cannot be imported (see above traceback.) Please make sure the module is installed or that the above ImportError is fixed.RnRt exceptions2One or more hosts failed while executing task '%s't exit_codeitresultss (,RWR^RR RRgR8R3R1RYRRRERZR RNRfR‹t ImportErrort tracebackt format_excRVROtQueueR RRRSt_debugRRRoRpRtmessageR\teagerly_disconnectRtcloseR>t iteritemsR€RqR}R (R'RR=R‰R—t is_callabletmsgt dunder_namet new_kwargsRARBRCReR‹R™ttbRORxRŠRˆR„Rterrtran_jobsR:td((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pytexecutes‚-                    '  (ii(+t __future__Rt functoolsRRRR tfabricRt fabric.utilsRRRtfabric.networkRRRtfabric.context_managersR tfabric.job_queueR tfabric.task_utilsR R R tfabric.exceptionsRt version_infotobjectRRR"RR0R5R6RZRfRmRqRRR©(((sZ/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/tasks.pyts4        O)    B