ó ÚaÎ]c@s´ddlZddlZddlZddlmZddlmZddlZddlZddl m Z d„Z de fd„ƒYZ edkr°ejd d d ejƒddlZdd lmZejd dƒZejdddddƒejddddddƒejddddddƒejdddeddƒejƒZejejƒZejZe eƒZx/ejD]!Zd efGHej eeƒqˆWndS(!iÿÿÿÿN(t OptionParser(tfromorg(tThreadcCsit|jƒƒ}|jƒddj|ƒdGHddjg|D]}t||ƒ^qBƒdGHdS(Nt|s | s |(tlisttkeystsorttjointstr(tdtltk((s*/home/dice/stardice/scheduler/scheduler.pyt dict_to_orgs t SchedulercBseeZd d„Zd„Zd„Zd d„Zd„Zd dd„Zd„Z d„Z d „Z RS( c Cs[t|_g|_||_|dkrBt|jjjƒƒ}n+g|D]}|t |j|ƒf^qI}g|D]-\}}|t t |ƒ|||ƒf^qt|_ x*|j D]\}}|j |j gƒq´W|jƒtjjƒ}d|j|j|jf}tjj|jjj|ƒ|_x'|j D]\}}t|||ƒq7WdS(sÉ Creates a scheduler instance that will handle a schedule and in particular handle taking the images Data will be saved in [config.Output.dir]/year-month-day/ s%04d-%02d-%02dN(tFalsetabortingt current_jobstconfigtNoneRt Subsystemst__dict__titemstgetattrt allsubsystemst subsystemst async_runt configureRtdatetimetnowtyeartmonthtdaytostpathtOutputt output_dirtsetattr( tselfRt device_listtnametcomptsRtoutput_dir_nowtsys((s*/home/dice/stardice/scheduler/scheduler.pyt__init__s    += !cCs3td|d|ƒ}|jj|ƒ|jƒdS(Nttargettargs(RRtappendtstart(R%tfuncR.tt((s*/home/dice/stardice/scheduler/scheduler.pyR7scCs-x&|jr(|jjƒ}|jƒqWdS(N(RtpopR(R%R2((s*/home/dice/stardice/scheduler/scheduler.pyR<s cCsà|dkr|j}ntjd|ƒ}tjt|ƒƒxdddgD]n}x[|jD]P\}}|jrt dƒ‚n||r]|j t ||ƒ||gƒq]q]W|j ƒqMWtjd|ƒ|j d|ƒS(sÖ Shoots an exposure: runs every subprocess before_exposure, exposure and after_exposure and dumps the exposure in output_dir. If output_dir isn't set, uses the scheduler output_dir R#tbefore_exposuretexposuretafter_exposuresAborted observation programsdumping files -> %sN(RR#t fitsbuildert FitsBuildertloggingtinfoRRRt StopIterationRRRtdump(R%tstateR#tfbR1R't subsystem((s*/home/dice/stardice/scheduler/scheduler.pytshootAs    &cCsFd}x9|jD].\}}|d|d7}||jƒ7}qW|S(sPrint system status ts s ---------- (RR=(R%tstR'R?((s*/home/dice/stardice/scheduler/scheduler.pyR=Zs ic csÊddlm}t|_tjd|ƒt|ƒ\}}|j|ƒ}xxt|||dƒD]_\}}t|_ xG|j sÁtjd|t |ƒfƒ|j ||ƒ} | |fVq{WqcWdS(Niÿÿÿÿ(t prog_fieldssExecuting program %sisProcessing exposure %d/%d( tstardice.obsprogRCRRR9R:Rtastypet enumeratetacceptedtlenR@( R%t program_fileR#t startlineRCtprogramR texpR5tfilename((s*/home/dice/stardice/scheduler/scheduler.pytexecuteds $  cCs t|_dS(N(tTrueR(R%((s*/home/dice/stardice/scheduler/scheduler.pytabortqscCsd|jj|jj}}ttd||fƒƒ}|dkrW|jj||ƒn|jjƒS(s@ Mount synchronisation with the result of last analysis s3Do you want set current pointing to %f,%f (y/n)? : ty(tanalysetfratfdectevaltinputtmountt set_radect get_radec(R%RSRTta((s*/home/dice/stardice/scheduler/scheduler.pyt mount_initts  cCs]i}xP|jD]E\}}t||sD      p