ó —Àv]c@@s|dZddlmZddlZddlZddlZddlZddlmZddl m Z d„Z d„Z dS( sSubmission job for local jobs.i(tabsolute_importN(tThreadi(ttrackerc C@sç|djdƒdkrStjj|dƒrStjdkrSd|d|d   !     c@sA‡fd†}tjˆjˆjd|ddjˆjƒƒdS(sSubmit function of local jobs.c @si}x€t||ƒD]n}||kr2d}nd}tdtdˆjˆj|||fƒ||<||jtƒ||jƒqWdS(s• customized submit script, that submit nslave jobs, each must contain args as parameter note this can be a lambda function containing additional parameters in input Parameters ---------- nworker: number of slave process to start up nserver: number of server nodes to start up envs: enviroment variables to be added to the starting programs tworkertserverttargettargsN(trangeRR-tcommandtlocal_num_attemptt setDaemonRtstart(tnworkertnservertenvstprocstiR$(R1(s3/tmp/pip-install-Qvdv_2/mxnet/dmlc_tracker/local.pytmthread_submit6s   .t fun_submittpscmdRN(Rtsubmitt num_workerst num_serversRR3(R1R<((R1s3/tmp/pip-install-Qvdv_2/mxnet/dmlc_tracker/local.pyR?4s( t__doc__t __future__RRRRRt threadingRtRR-R?(((s3/tmp/pip-install-Qvdv_2/mxnet/dmlc_tracker/local.pyts     (