a ƹDf@s@dZddlmZmZmZddlmZddZ ddZ e dkr>> def rangetotal(n): return n, sum(range(n)) >>> list(map(rangetotal, range(1, 6))) [(1, 0), (2, 1), (3, 3), (4, 6), (5, 10)] >>> list(ppmap(1, rangetotal, range(1, 6))) [(1, 0), (2, 1), (3, 3), (4, 6), (5, 10)] )*serverN ppserverscstdj|tdS)zSend a job to the serverr)globals)rsubmitr )argsfunctionZ/nfs/NAS7/SABIOD/METHODE/ermites/ermites_venv/lib/python3.9/site-packages/pathos/pp_map.pyr iszppmap..submitZ autodetectcss|] }|VqdS)Nr).0Zsubprocrrr zppmap..)rgetppServerextendZ set_ncpusmap)Z processesrsequence sequencesr r arr rppmap<s   rcOsd}d}d|vr"|d}|dd|vr<|d}|dd|vrN|dd|vr`|dd|vrr|dd|vr|dd |vr|d d |vr|d d |vr|d td dst|d td <}tt|||g|RS)a'extend python's parallel map function to parallel python Args: function - target function sequence - sequence to process in parallel ncpus - number of 'local' processors to use [defaut = 'autodetect'] servers - available distributed parallel python servers [default = ()] NrZncpusserversZnnodesnodeslauncherZmapperqueueZ timelimitZ schedulerrr)poprrrlistr)rrr kwdsZprocsrZ job_serverrrrpp_maps$    r#__main__N) __doc__Z pathos.pprrrZ print_statsZpathos.helpers.pp_helperrrrr#__name__rrrr+s   U