o wi@sddlmZddlmZddlmZddlmZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZddlZe jddZedkr^ddlmZnddlZd d Ze jd krudXd d Zedn edZdXddZzeWn e ye!ZYnwddZ"eddZ#ddZ$ddZ%ddZ&ddZ'e j(dkZ)Gdd d e*Z+d!d"Z,dYd$d%Z-d&d'Z.Gd(d)d)e/Z0Gd*d+d+e/Z1Gd,d-d-ej2Z3d.d/Z4e4ej5_4dZd0d1Z6z e j78d2d39d4Z:Wn e;ed5e j7d6d7Ze>dgdDZ?Gd?d@d@e>Z@GdAdBdBe>ZAdCdDZBGdEdFdFe>ZCGdGdHdHe/ZDGdIdJdJe jEZFGdKdLdLe/ZGGdMdNdNeGZHGdOdPdPeGZI GdQdRdRe/ZJGdSdTdTe/ZKd[dVdWZLdS)\)with_statement)contextmanager) attrgetter)gettextN)) load_sourcecCs*tj||}tj|}|j||SN) importlibutilspec_from_file_locationmodule_from_specloader exec_module)dotnamepathspecmodrE/home/ubuntu/sommelier/.venv/lib/python3.10/site-packages/plac_ext.pyr s  r 3cCsB|durtd}|j}|dur|j}~n|dur|}tddS)Nzexec _code_ in _globs_, _locs_)sys _getframe f_globalsf_localsexec)_code__globs__locs_framerrrexec_#s  r"z> def raise_(tp, value=None, tb=None): raise tp, value, tb rcCsH|dur t|tr td|dur||}n|}|j|ur"|||)z A function that matches the Python 2.x ``raise`` statement. This allows re-raising exceptions with the cls value and traceback on Python 2 and 3. Nz0instance exception may not have a separate value) isinstance Exception TypeError __traceback__with_traceback)tpvaluetbexcrrrraise_5s   r,cCs(z|dWStyt|YSw)z: Decode an object assuming the encoding is UTF-8. zutf-8)decodeAttributeErrorstr)valrrrr-Ks    r-ccs*tj}|t_z dVW|t_dS|t_w)z8usage: with stdout(file('out.txt', 'a')): do_something()N)rstdout)fileobj orig_stdoutrrrr1Ys r1cCstjt|tjdS)z2Write str(x) on stdout and flush, no newline addedN)rr1writer/flush)xrrrr4dsr4ccs |VdS)z/Return a generator object with a single elementNr)r)rrrgen_valjs r7ccst|||dVdS)z.Return a generator object raising an exceptionN)r,)etyper+r*rrrgen_excos  r9cCsNtjddgtjd}z|j|Wn tyYnw|j|dS)zSend a text to less via a pipeless-c)stdinN) subprocessPopenPIPEr<r4IOErrorclosewait)textporrrr:us   r:win32c@ eZdZdS)TerminatedProcessN__name__ __module__ __qualname__rrrrrGrGcCstr )rG)signumr!rrrterminatedProcessrNcCs$t|tr ||St||S)z4Read a line from stdin, using readline when possible)r# ReadlineInputreadliner4)r<promptrrr read_lines  rTccsb g} |}|s dS|}|sq|d|kr$||ddn||qd|Vq)z Read multiple lines from stdin until the terminator character is found, then yield a single space-separated long line. TN )rRstripappendjoin)r< terminatorlineslinerrrread_long_lines"   r]c@sDeZdZdZdddZddZdd Zd d Zdd dZddZ dS)rQzA An iterable with a .readline method reading from stdin. TNcCsN||_||_||_|sdd|D|_ddl}||_|d||jdS)NcSg|]}|qSr)upper).0crrr z*ReadlineInput.__init__..rz tab: complete) completionscase_sensitivehistfilerRrlparse_and_bind set_completercomplete)selfrdrerfrRrrr__init__s zReadlineInput.__init__cCsB|j|_z|jr|j|jW|SW|Sty Y|Swr )rg get_completer old_completerrfread_history_filer@rkrrr __enter__s  zReadlineInput.__enter__cCs*|j|j|jr|j|jdSdSr )rgrirnrfwrite_history_file)rkr8r+r*rrr__exit__szReadlineInput.__exit__cs>|jsz fdd|jD|WStyYdSw)Ncsg|] }|r|qSr startswith)r`kkwrrrbz*ReadlineInput.complete..)rer_rd IndexError)rkrxstaterrwrrjs zReadlineInput.completerPcCs$zt|dWStyYdSw)N rP) raw_inputEOFError)rkrSrrrrRs  zReadlineInput.readlinecCs t|jdSNrP)iterrRrprrr__iter__ zReadlineInput.__iter__)TNrP) rIrJrK__doc__rlrqrsrjrRrrrrrrQs    rQc@s4eZdZdZeddZddZddZdd Zd S) HelpSummaryz7Build the help summary consistently with the cmd modulecCst|}tj|d}|jd|dt|dd|dt|jdd|dt|j dd|dt|j ddt |j|_ dS) N)r1r|special commandsPzcustom commands"commands run in external processesthreaded commands) plac_core parser_fromcmdCmdr1r4 print_topicssortedcommands mpcommands thcommandsr/ helpsummary)clsobjspecialcommandsprarrradds      zHelpSummary.addcCs g|_dSr )_lsrprrrrls zHelpSummary.__init__cC|j|dSr )rrX)rksrrrr4zHelpSummary.writecCs d|jSr)rYrrprrr__str__rzHelpSummary.__str__N) rIrJrKr classmethodrrlr4rrrrrrs  rcseZdZfddZZS) PlacFormattercs4|jpi}tdd|D|_tt|||S)z.Remove special commands from the usage messagecss&|]\}}|ds||fVqdS).Nrt)r`nrarrr s z3PlacFormatter._metavar_formatter..)choicesdictitemssuperr_metavar_formatter)rkactiondefault_metavarr __class__rrrs  z PlacFormatter._metavar_formatter)rIrJrKr __classcell__rrrrrsrcCs,z|jWStyttj|YSw)z:Attached to plac_core.ArgumentParser for plac interpreters)rr.rrArgumentParser format_helprprrrrs  rccst|}|dur|VdS|jj|}|dur%td|VdSt|ddro|}||_ | |j dd|j D|j ||j|jD]}||j||j|dd|jD|qJ|VdS|VdS) z3The default help functionality in plac interpretersNzUnknown command %s _interact_FcSsg|] }|jdkr|qS)helpdestr`arrrrbryz default_help..css|] }|jdkr|VqdS)rNrrrrrr!s  zdefault_help..)rrr subparsers_name_parser_mapget_getattr_get_formatter_prog add_usageusage_actions_mutually_exclusive_groupsadd_text description_action_groups start_sectiontitle add_arguments_group_actions end_section)rrparsersubp formatter action_grouprrr default_helps.        rPLACPATHr:z#Ill-formed PLACPATH: got %PLACPATHscCst|j}|js|js|jrtdd|j}|r|d7}d||f}t |d}t |||d}d|_ t |rDt|jdi|_nt|di|_d |jd <t||S) zBCall a container factory with the arglist and return a plac objectzJInterpreter.call must be invoked on factories with required arguments onlyz, ,zzdef makeobj(interact, %s *args): obj = factory(%s) obj._interact_ = interact obj._args_ = args return obj )factorymakeobjF__annotations__)zstart interactive interpreterflagiinteract)rrargspecdefaultsvarargsvarkwr%rYargsrr"add_helpinspectisclassrrlrcall)rarglistr required_argscodedicrrrr partial_call0s,       rc Gsd|vr |d\}}nd}tj|s1tD]}tj||}tj|r'n qttd|n|}tj tj |\}}t ||}|rPt t |||}|S|j}|S)zs A utility to import the main function of a plac tool. It also works with command container factories. rNzCannot find %s)splitosrisabsPLACDIRSrYexists ImportErrorrsplitextbasenamer rrmain) rr factory_nameplacdirfullpathnameextmoduletoolrrr import_mainMs&   rc@sneZdZdZdZddZddZddd Zd d Zd d Z ddZ ddZ e ddZ e ddZddZdS)BaseTaskz A task is a wrapper over a generator object with signature Task(no, arglist, genobj), attributes .no .arglist .outlist .str .etype .exc .tb .status and methods .run and .kill. ) SUBMITTEDRUNNING TOBEKILLEDKILLEDFINISHEDABORTEDcCs<||_||_|||_d\|_|_|_|_d|_g|_ dS)N)rPNNNr) nor_wrap_genobjr/r8r+r*statusoutlistrkrrgenobjrrrrl|s   zBaseTask.__init__cCdS)z2Notifies the underlying monitor. To be implementedNrrkmsgrrrnotifyzBaseTask.notifyFc csd|_z"|D]}|jdkrt|dur!|j||t|dVqWn>tjy3|tt t fyBd|_YdSt ydt \|_|_}|r[dt|n||_d|_YdSw|dS)z Wrap the genobj into a generator managing the exceptions, populating the .outlist, setting the .status and yielding None. stringify_tb must be True if the traceback must be sent to a process. rrNrrPr)r GeneratorExitrrXrr- InterpreterExit _regular_exitrGKeyboardInterruptr$rexc_infor8r+rY traceback format_tbr*)rkr stringify_tbr)r*rrrrs,      zBaseTask._wrapcCs<d|_z dtt|j|_WdStyd|_YdSw)Nrr|z no result)rrYmapr-rr/rzrprrrr s   zBaseTask._regular_exitcCs|jD]}qdS)zRun the inner generatorN)r)rknonerrrruns z BaseTask.runcCs d|_dS)zSet a TOBEKILLED statusrNrrprrrkills z BaseTask.killcCr)z-Wait for the task to finish: to be overriddenNrrprrrrBrz BaseTask.waitcCs6|jdurdSt|jttfr|jSdt|jS)z1Return the traceback as a (possibly empty) stringNrP)r*r#r/bytesrYrrrprrrrs zBaseTask.tracebackcCsT||jr t|jttfr||jt|j|j|jpd|js%dS|jdS)NrU) rBr+r#r*r/rr8r,rrprrrresults  zBaseTask.resultcCs d|jj|jd|j|jfS)zDString representation containing class name, number, arglist, statusz<%s %d [%s] %s>rV)rrIrrYrrrprrr__repr__s zBaseTask.__repr__NF)rIrJrKrSTATESrlrrr rrrBpropertyrrrrrrrrks     rccs|]}dVqdS)skipNr)r`dummyrrrrsr)rc@seZdZdZddZdS)SynTaskzn Synchronous task running in the interpreter loop and displaying its output as soon as available. cCs*|jr d|jj|jfSdtt|jS)z-Return the output string or the error messagez%s: %sr|)r8rIr+rYrr/rrprrrrszSynTask.__str__N)rIrJrKrrrrrrrs rcs0eZdZdZfddZddZddZZS) ThreadedTaskz/ A task running in a separated thread. cs*t||||tjtt|jd|_dS)Ntarget)rrl threadingThreadrr rthreadrrrrrlszThreadedTask.__init__cC|jdS)zRun the task into a threadN)r%startrprrrrzThreadedTask.runcCr&)zBlock until the thread endsN)r%rYrprrrrBr(zThreadedTask.wait)rIrJrKrrlrrBrrrrrr s  r cs$fdd}fdd}t||S)z-Return a property to be attached to an MPTaskcszt|jWSYSr )rnsrpron_errorrrrszsharedattr..getcs"z t|j|WdSYdSr )setattrr))rkr))rrrsetszsharedattr..set)r)rr+rr-rr*r sharedattrs  r.cs~eZdZdZeddZeddZeddZeddZedd Z e d d Z d d Z fddZ ddZddZddZZS)MPTaskz A task running as an external process. The current implementation only works on Unix-like systems, where multiprocessing use forks. r/rPr8Nr+r*rrcCsz|jWSgYSr )_outlistrprrrrszMPTask.outlistcCs|j|j|dSr )mannotify_listenerrrrrrrsz MPTask.notifycst||_||_|j|dd|_||_|j|_|j|_ d|_ d\|_ |_ |_ t||_tjtt|jd|_dS)zS The monitor has a .send method and a .man multiprocessing.Manager T)rrNNNr!N)rrrrr1mplistr0 Namespacer)rr8r+r*reprr/multiprocessingProcessrr/rproc)rkrrrmanagerrrrrls   zMPTask.__init__cCr&)z%Run the task into an external processN)r:r'rprrrr+r(z MPTask.runcCr&)z2Block until the external process ends or is killedN)r:rYrprrrrB/r(z MPTask.waitcCr&)z^Kill the process with a SIGTERM inducing a TerminatedProcess exception in the childrenN)r: terminaterprrrr3sz MPTask.kill)rIrJrKrr.r/r8r+r*rrrrrlrrBrrrrrrr/s       r/c@seZdZdZdZedgZddZddZdd d Z e j d d d e fddddZ e j dd d eejfddddZe j dd d e fddddZe j dd d e fddddZd S) TaskManagerzl Store the given commands into a task registry. Provides methods to manage the submitted tasks. rz.last_tbcCs||_i|_|js |jr|jgdt|dd}tj||r!dndt d|_ t ||j|jr4t nd|_ttjtdS)N)z.killz.listz.outputrFrP)progformatter_class)rregistryrrrupdaterrrrrrrManagerr1signalSIGTERMrN)rkrrrrrrlCs  zTaskManager.__init__cCsP|jD]}z|jdkr||WqYq|jr&|jdSdS)zKill all the running tasksrN)r@valuesrrrBr1stop)rktaskrrrrAOs zTaskManager.closerUNcsn|dksJdrfdd|jD}n dd|jD}|jtddt|t|kr5||SdS) z/Get the latest submitted task from the registryrzYou must pass a negative numbercsg|] }|jkr|qSrrr`trrrrb_s z+TaskManager._get_latest..cSsg|]}|qSrrrHrrrrbbsr)keyN)r@rEsortrlenabs)rktasknortasksrrr _get_latest[szTaskManager._get_latestz task to kill positional)rNccsx|dkr|j|dd}|durdVdSn||jvr"d|VdS|j|}|jdvr3d|VdS||VdS) z8kill the given task (-1 to kill the latest running task)rrrNzNothing to killUnknown task %d)rrrzAlready finished %s)rPr@rrrkrNrGrrrris       zTaskManager.killrPrrccs&|jD] }|j|kr|VqdS)zlist tasks with a given statusN)r@rEr)rkrrGrrrr5}s  zTaskManager.listz task numberccs|dkr||}|durdVdSn||jvr d|VdS|j|}dtt|j}|rAt|d|d||fVdS|Vt|jdkrSt rSt |dS|VdS) zBshow the output of a given task (and optionally save it to a file)rNNothing to showrRr|wzsaved output of %d into %s) rPr@rYrr/ropenr4rLuse_lessr:)rkrNfnamerGoutstrrrroutputs(      zTaskManager.outputccs&||}|r|jVdSdVdS)z*show the traceback of a given task, if anyrTN)rPrrSrrrlast_tbs    zTaskManager.last_tb)rUN)rU)r)rIrJrKr cmdprefixr-rrlrArPr annotationsintrr/rrr5r[r\rrrrr=;s.        r=c@s0eZdZdZddZddZddZdd Zd S) r9z=Start the interpreter specified by the params in a subprocesscCsPttjtjd|d|f}tjj|tjdd|gtjtjdt |_ dS)Nzfimport plac, sys sys.argv[0] = '<%s>' plac.Interpreter(plac.import_main(*%s)).interact(prompt='i>\n') rz-ur;)r<r1) rCSIGPIPESIG_DFLr=r>rlr executabler?r8rBr1)rkparamsrrrrrls zProcess.__init__cCs"|j|j|jdS)zClose stdin and stdoutN)r<rAr1r1shutdownrprrrrAs  z Process.closecCs>g} ||j|ddkrd|}|dddSq)zBReturn the output of the subprocess, line-by-line until the promptTrUzi> rPNrV)rXr1rRrY)rkr[outrrrrecvs  z Process.recvcCs|j|tj|S)z[Send a line (adding a newline) to the underlying subprocess and wait for the answer)r<r4rlineseprf)rkr\rrrsendsz Process.sendN)rIrJrKrrlrArfrhrrrrr9s   r9c@ eZdZdZddZddZdS)StartStopObjectFcCdSr rrprrrr'rOzStartStopObject.startcCrkr rrprrrrFrOzStartStopObject.stopN)rIrJrKstartedr'rFrrrrrjs rjc@sJeZdZdZdddZddZddZd d Zd d Zd dZ ddZ dS)Monitorzv Base monitor class with methods add_listener/del_listener/notify_listener read_queue and and start/stop. NcCs||_|pt|_dSr )rr8Queuequeue)rkrrorrrrlszMonitor.__init__cCrkr rrkrNrrr add_listenerrOzMonitor.add_listenercCrkr rrprrr del_listenerrOzMonitor.del_listenercCrkr r)rkrNrrrrr2rOzMonitor.notify_listenercCrkr rrprrrr'rOz Monitor.startcCrkr rrprrrrFrOz Monitor.stopcCrkr rrprrr read_queuerOzMonitor.read_queuer ) rIrJrKrrlrqrrr2r'rFrsrrrrrms  rmc@sHeZdZdZddZddZddZdd Zd d Zd d Z ddZ dS)rBz The plac Manager contains a multiprocessing.Manager and a set of slave monitor processes to which we can send commands. There is a manager for each interpreter with mpcommands. cCsi|_d|_d|_dSNF)r@rlr4rprrrrls zManager.__init__cCs*td|j|j}|j|_||j|j<dS)z(Add or replace a monitor in the registryN)r8r9r'rror@)rkmonitorr:rrrrsz Manager.addcCs |j|=dS)z(Remove a named monitor from the registryN)r@rkrrrrdelete zManager.deletecCs6|jdur t|_|jD]}|qd|_dS)NT)r4r8rBr@rEr'rlrkrurrrr' s    z Manager.startcCsB|jD] }|j|q|jr|jd|_d|_dSrt)r@rErorAr<r4rdrlryrrrrFs    z Manager.stopcCs&|jD] }|jd||fqdS)Nr2r@rEroput)rkrNrrurrrr2szManager.notify_listenercCs$|jD] }|jd|fqdS)Nrqrz)rkrrurrrrq szManager.add_listenerN) rIrJrKrrlrrwr'rFr2rqrrrrrBs rBc@seZdZdZGdddeZdejfddZddZ d d Z d d Z d dZ ddZ ddZd3ddZddZddZddZd4ddZd4dd Zejd!dfd"d#Zejd$dfd%d&Zd'd(Zd5d*d+Zd,d-Zd.d/Zeejd0ddejejd$dfd1d2ZdS)6r zi A context manager with a .send method and a few utility methods: execute, test and doctest. c@rF)zInterpreter.ExitNrHrrrrr xrLr #cCs||_z|j|_Wn tyd|_Ynw||_||_||t||_|jj |_ |jj |_ |j r?|j j |jj |jdd|jrL|j j |j|dd|jrY|j j |j|dddd|j _d|_dS)Nplacr)rrrcSs t|Sr )rexit)rrrrs z&Interpreter.__init__..)rrJrr. commentcharr _set_commandsr=tmr1rraddsubcommandsrrrerror _interpreter)rkrrrrrrrl{s6          zInterpreter.__init__c CsdD]}t||tt|j|gt||tt||gq|j|_|j|j|j|j|js9|js9|jrPt|dsNt ||j|_ |j ddSdSdS)z=Make sure obj has the right command attributes as Python sets)rrrrN) r,r-rrrrrArhasattrr__get__rr)rkrattrnamerrrrszInterpreter._set_commandscCs||_|jd|S)z Start the inner interpreter loopN)_make_interpreterrrhrprrrrqs  zInterpreter.__enter__cCs||||dS)z0Close the inner interpreter and the task managerN)rArkexctyper+r*rrrrsszInterpreter.__exit__cCs|jdur ttd|t|ttfr|||j}n|}|s"tS|j j }|r/|j s/| |j |}t|d|j jsN||j j|j<|rN||j|S)zBSend a line to the underlying interpreter and return a task objectNzA%r not initialized: probably you forgot to use the with statementr)r RuntimeErrorrr#r/rrrnulltaskrr1rlr'rhr _match_cmdrr@rrq)rkr\rmrGrrrsubmits$    zInterpreter.submitcCs||}t||S)zNSend a line to the underlying interpreter and return the finished task)rrrrkr\rGrrrrhs  zInterpreter.sendcCs |jjS)z%The full lists of the submitted tasks)rr@rErprrrrOrxzInterpreter.tasksNcCs4|j|dur|j|||dS|jdS)z2Can be called to close the interpreter prematurelyN)rrArthrowrrrrrAs zInterpreter.closec csbt|jddd}t|jddd}|d}ztdD]v}|V}z |j|\}}Wn5tyT}z|jdkr=g} nt|g} t ||t | }WYd}~qd}~wt ||t t }Yqt|sqt ||t|}q||jjvrt||||jj}q||jjvrt|||}qt |||}qWdSty|dddYdS|t ) zBThe interpreter main loop, from lists of arguments to task objectsrqcSrkr rrrrrrrz/Interpreter._make_interpreter..rscSrkr r)etexr*rrrrrNr)r)rr itertoolscountrconsume SystemExitrr/rrr9rrriterabler7rr/rr1rr r ) rkenterr~rGrrrreerrlistrrrrsB        zInterpreter._make_interpretercCs2||j}||k}|sd|||f}t|dS)z:Make sure you get the expected_output from the given_inputz!input: %s output: %s expected: %sN)rhr/AssertionError)rk given_inputexpected_outputr[okrrrrchecks zInterpreter.checkc Csdd|D}g}g}t|D]\}}|dr&||dd||q|t|dg}t|ddD]\}}||d} |d||d| q:t|||S) zDReturns the lines of input, the lines of output, and the line numbercSr^r)rW)r`r\rrrrbrcz.Interpreter._parse_doctest..i> rNrrUr|) enumeraterurXrLrYzip) rklineiterr[inputs positionsrr\outputsr'endrrr_parse_doctests    zInterpreter._parse_doctestFc Cs|\z@||D]8\}}}|rtd|td|||}t||ksAd|d|||f}t||jrAt|j|j|jq Wn |jyMYn wWddSWddS1sawYdS)z Parse a text containing doctests in a context and tests of all them. Raise an error even if a single doctest if broken. Use this for sequential tests which are logically grouped. zi> %s z-> %s z+line %d: input: %s output: %s expected: %s rN) rr4rhr/r+r,r8r*r )rkrverboseinputr[rrGrrrrdoctests.     "zInterpreter.doctestc Cs|Cz'|D]"}|rtd|||}|jr!t|j|j|jtd|jqWn |jy4Yn wWddSWddS1sHwYdS)z@Execute a lineiter of commands in a context and print the outputr%s N)r4rhr8r,r+r*r/r )rkrrr\rGrrrexecute&s"   "zInterpreter.execute;c Cs|@z$t||D]}||}|td|j|r%|jr%t|jq Wn |jy1Yn wWddSWddS1sEwYdS)z       "zInterpreter.interactcs|z2tfdddD]%}|}|sq |}|tt|djr/|jr/t|jq WdSj y=YdSw)z5Convert input lines into task which are then executedcstjjSr )rTr<rSrrprrr^sz+Interpreter._manage_input..rPr|N) rrWrrr4r/rr8rr rrrprr[s    zInterpreter._manage_inputc Ks`t|t|z$z tjdi|Wn ttfyYnwWtdSWtdStw)zqStarts an asyncore server reading commands for clients and opening a new interpreter for each connection.Nr) _AsynServer _AsynHandlerasyncoreloopr rG close_all)rkportrxrrr start_serverjs  zInterpreter.start_servercCrr )r1r)rkmonrrr add_monitorurzInterpreter.add_monitorcCrr )r1rwrvrrr del_monitorxrzInterpreter.del_monitorrc Cst||}||||} | jjrI| .| | jj} | jr%t| j| j| jt| } | r7t | WddSWddS1sBwYdS| jj rV| |||dS| j dS)z Call a container factory with the arglist and instantiate an interpreter object. If there are remaining arguments, send them to the interpreter, else start an interactive session. N)rr_args_rhr+r,r8r*r/printrrr print_usage) rrrrrr<rSrrrrGrerrrr{s  "zInterpreter.callr3r)r) rIrJrKrr$r shlexrrlrrqrsrrhrOrArrrrrrr<rrrrrrrargvrrrrrr ss6  #      r c@ri) _TaskLauncherzHelper for runpcCs(|dkr dg|_ndg|_t||_dS)Nrrungen)rrr5genlist)rkgenseqmoderrrrls z_TaskLauncher.__init__ccs$|jt|dD]}|Vq dS)Nr)rr_)rkrrerrrrsz_TaskLauncher.rungenN)rIrJrKrrlrrrrrrs rrc Cs|dvsJ|t||}g}t|D}tt|jD] }|d|dq|D]!}z||j Wq-t yN}z ||WYd}~q-d}~wwWd|S1sZwY|S)zRun a sequence of generators in parallel. Mode can be 'p' (use processes) or 't' (use threads). After all of them are finished, return a list of task objects. ptz rungen %drN) rr rangerLrrrrOrXrr$)rrlauncherresinterrrGrrrrrunps$    r)NNrr )r)M __future__r contextlibroperatorrrrrrrrrr=argparserrr8rCr#r version_infoversionimpr importlib.utilr r"revalr,r} NameErrorrr-r1r4r7r9r:platformrXr$rGrNrTr]objectrQrRawDescriptionHelpFormatterrrrrenvironrrr ValueErrorrrrrrr r.r/r=r>r9rjrmrBr rrrrrrs              2  g 4p% 3J%