ó —Ŕv]c@@sKdZddlmZddlZddlZddlmZd„ZdS(sSubmit jobs to Sun Grid Engine.i(tabsolute_importNi(ttrackerc@sMˆjdkr:dˆjˆjdjdƒdˆ_nˆjdkr\ˆjdˆ_ntjjˆjƒrŸtjj ˆjƒsŻt dˆjƒ‚qŻntj ˆjƒdˆj ‰t ˆdƒ}|jd ƒ|jd ƒ|jd ƒ|jd ƒ|jƒ‡‡fd †}tjˆjˆjd|ddjˆjƒƒdS(sJob submission script for SGE.sdmlc%d.it/i˙˙˙˙s.logs'specified --sge-log-dir %s is not a dirs %s/rundmlc.shtwssource ~/.bashrc s#export DMLC_TASK_ID=${SGE_TASK_ID} sexport DMLC_JOB_CLUSTER=sge s"$@" c@súdjg|jƒD]"\}}d|t|ƒf^qƒ}d||}ˆjdkro|dˆj7}n|dˆj7}|dˆjˆjf7}|dˆj7}|d |7}|d ˆd jˆjƒf7}|GHtj |d t ƒd GHdS(sInternal submission function.t,s%s="%s"sqsub -cwd -t 1-%d -S /bin/bashtdefaults-q %ss -N %s s -e %s -o %ss -pe orte %ds -v %s,PATH=${PATH}:.s %s %st tshells!Waiting for the jobs to get up...N( tjointitemststrtqueuetjobnametlogdirtvcorestcommandt subprocesst check_calltTrue(tnworkertnservert pass_envstktvtenv_argtcmd(targst runscript(s1/tmp/pip-install-Qvdv_2/mxnet/dmlc_tracker/sge.pyt sge_submits> t fun_submittpscmdRN(R tNonet num_workersRtsplitt sge_log_dirtostpathtexiststisdirt RuntimeErrortmkdirR topentwritetcloseRtsubmitt num_serversR(RtfoR((RRs1/tmp/pip-install-Qvdv_2/mxnet/dmlc_tracker/sge.pyR, s&+      (t__doc__t __future__RR#RtRR,(((s1/tmp/pip-install-Qvdv_2/mxnet/dmlc_tracker/sge.pyts