pathos API reference
59 public APIs from pathos (uqfoundation/pathos) — 17 classes, 11 functions, 31 methods. Signatures extracted by static analysis of the actual source.
Repository: uqfoundation/pathos
| Kind | Count |
|---|---|
| Classes | 17 |
| Functions | 11 |
| Methods | 31 |
API list
func
examples2.all_scatter_gather.sin2(xi)sin squared of all data
func
examples2.all_scatter_gather2.sin_diff(x, xp)d = sin(x - x')
class
pathos.abstract_launcher.AbstractPipeConnectionAbstractPipeConnection base class for pathos pipes.
class
pathos.abstract_launcher.AbstractWorkerPoolAbstractWorkerPool base class for pathos pools.
method
pathos.abstract_launcher.AbstractWorkerPool.clear()Remove server with matching state
func
pathos.citation()print citation
class
pathos.connection.Pipea popen-based pipe for parallel and distributed computing
method
pathos.connection.Pipe.kill()terminate the pipe
method
pathos.connection.Pipe.launch()launch a configured command
method
pathos.connection.Pipe.pid()get pipe pid
class
pathos.connection.PipeExceptionException for failure to launch a command
func
pathos.helpers.mp_helper.random_seed(s=None)sets the seed for calls to 'random()'
func
pathos.hosts.get_profiles()get $PROFILE for each registered host
func
pathos.hosts.register(rhost, profile=None)register a host and $PROFILE
func
pathos.license()print license
method
pathos.maps.Map.clear()remove pool singleton, if exists
method
pathos.maps.Map.close()close the map to any new jobs
method
pathos.maps.Map.join()reclaim the closed workers
class
pathos.multiprocessing.ProcessPoolMapper that leverages python's multiprocessing.
method
pathos.multiprocessing.ProcessPool.close()close the pool to any new jobs
method
pathos.multiprocessing.ProcessPool.join()cleanup the closed worker processes
method
pathos.multiprocessing.ProcessPool.restart(force=False)restart a closed pool
method
pathos.multiprocessing.ProcessPool.terminate()a more abrupt close
class
pathos.parallel.ParallelPoolMapper that leverages parallelpython (i.e.
method
pathos.parallel.ParallelPool.close()close the pool to any new jobs
func
pathos.parallel.ParallelPool.imap_unordered(it)build a unordered map iterator
method
pathos.parallel.ParallelPool.join()cleanup the closed worker processes
method
pathos.parallel.ParallelPool.restart(force=False)restart a closed pool
func
pathos.parallel.ParallelPool.submit(*argz)send a job to the server
method
pathos.parallel.ParallelPool.terminate()a more abrupt close
func
pathos.pp_map.submit(*args)Send a job to the server
class
pathos.profile.profiledecorator for profiling a function (will enable profiling)
func
pathos.profile.thread_id()get the identifier for the current thread
class
pathos.secure.connection.Pipea popen-based ssh-pipe for parallel and distributed computing.
class
pathos.secure.copier.Copiera popen-based copier for parallel and distributed computing.
class
pathos.secure.copier.FileNotFoundException for improper source or destination format
class
pathos.secure.tunnel.Tunnela ssh-tunnel launcher for parallel and distributed computing.
method
pathos.secure.tunnel.Tunnel.disconnect()destroy the ssh tunnel
class
pathos.secure.tunnel.TunnelExceptionException for failure to establish ssh tunnel
class
pathos.selector.SelectorSelector object for watching and event notification.
class
pathos.serial.SerialPoolMapper that leverages standard (i.e.
method
pathos.serial.SerialPool.clear()hard restart
method
pathos.serial.SerialPool.close()close the pool to any new jobs
method
pathos.serial.SerialPool.join()cleanup the closed worker processes
method
pathos.serial.SerialPool.restart(force=False)restart a closed pool
method
pathos.serial.SerialPool.terminate()a more abrupt close
method
pathos.server.Server.deactivate()turn off the selector
method
pathos.server.Server.selector()get the selector
method
pathos.server.Server.serve(timeout)begin serving, and set the timeout
class
pathos.threading.ThreadPoolMapper that leverages python's threading.
method
pathos.threading.ThreadPool.close()close the pool to any new jobs
method
pathos.threading.ThreadPool.join()cleanup the closed worker processes
method
pathos.threading.ThreadPool.restart(force=False)restart a closed pool
method
pathos.threading.ThreadPool.terminate()a more abrupt close
class
pathos.xmlrpc.server.XMLRPCRequestHandlercreate a XML-RPC request handler
method
pathos.xmlrpc.server.XMLRPCRequestHandler.do_POST()Access point from HTTP handler
class
pathos.xmlrpc.server.XMLRPCServerextends base pathos server to an XML-RPC dispatcher
method
pathos.xmlrpc.server.XMLRPCServer.activate()install callbacks
method
pathos.xmlrpc.server.XMLRPCServer.serve()enter the select loop...
About this data
These signatures were extracted from the public source of uqfoundation/pathos
using Python's ast module. Argument names, default values,
type annotations and return types are taken verbatim from the code.
Implementation bodies are never stored. See
how it works for details.