ó
á™xTc           @   s¦  d  d l  m Z e d k r¢d  d l Z e j d d d d ƒ Z e j d d	 d
 ƒe j d d	 d
 ƒe j d d d d	 d ƒe j d d e d d d	 d ƒe j ƒ  Z	 d  d l
 Z
 d  d l Z e
 j e	 j ƒ e j j e
 j j e	 j ƒ ƒ d  d l m Z e j d e	 j ƒ Z e j d e	 j ƒ Z d  d l m Z e j d e j d d „  ƒ d e	 j ƒ Z e j d e j d e j d e ƒ Z  e j! e _ e  j" ƒ  n  d S(   iÿÿÿÿ(   t   divisiont   __main__Nt   descriptions3   Server process handling far end of remote executiont   usages9   %(prog)s job-factory queue-factory (do not run directly!)t   jobt   helps   Job factory pickle stringt   queues   --foldert   defaultt   .s   Process workdirs
   --polltimet   typeg{®Gáz„?s   Poll intervall(   t   remotet   arg(   t
   schedulingt   handlert   factoryc        	   C   s+   t  j d t d t  j d t ƒ  d d ƒ ƒ S(   NR   t	   processorR   t   timeouti   (   R   t   ExecutionUnitt   jfactt   RetrieveProcessort   qfact(    (    (    sS   /public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/command_line/remote_processing.pyt   <lambda>*   s    	t   polling_intervalt   instreamt	   outstreamt   manager(#   t
   __future__R    t   __name__t   argparset   ArgumentParsert   parsert   add_argumentt   intt
   parse_argst   paramst   ost   syst   chdirt   foldert   patht   appendt   abspatht   libtbx.queuing_system_utilsR
   t   argument_to_objectR   R   R   R   R   t	   Schedulert	   Unlimitedt   polltimeR   t   SchedulerServert   stdint   stdoutt   servert   stderrt   serve(    (    (    sS   /public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/command_line/remote_processing.pyt   <module>   sH   								