zeppy package
zeppy.eppyREPserver module
zeppy.eppyREQclient module
zeppy.ppipes module
parallel pipeline functions
-
zeppy.ppipes.args_kwargs_helper(args_kwargs_list)[source]
-
zeppy.ppipes.clean_args_kwargs(args_kwargs)[source]
-
zeppy.ppipes.eplaunch_run(idf)[source]
-
zeppy.ppipes.idf_multirun(idf_kwargs)[source]
-
zeppy.ppipes.idf_run(idf)[source]
-
zeppy.ppipes.idfversion(idf)[source]
-
zeppy.ppipes.ipc_parallelpipe(func, args_list, nworkers=None, verbose=False, sleeptime=0.1)[source]
distributed run of the func using zmq
Returns the results of all the run
-
zeppy.ppipes.make_options(idf)[source]
-
zeppy.ppipes.measure(func)[source]
-
zeppy.ppipes.randstr(strlength)[source]
return a string of length strlength
-
zeppy.ppipes.runeverything()[source]
-
zeppy.ppipes.wait_add(first, second)[source]
wait for the sum of first and second. return the sum
-
zeppy.ppipes.wait_add_mult(first, add=0, mult=1)[source]
calculate the result=(first+add)*mult. Then waitsome(result)
-
zeppy.ppipes.waitsome(seconds)[source]
wait for some seconds
zeppy.ptcp module
parallel pipeline tcp functions
-
zeppy.ptcp.args_kwargs_helper(args_kwargs_list)[source]
-
zeppy.ptcp.clean_args_kwargs(args_kwargs)[source]
-
zeppy.ptcp.eplaunch_run(idf)[source]
-
zeppy.ptcp.idf_multirun(idf_kwargs)[source]
-
zeppy.ptcp.idf_run(idf)[source]
-
zeppy.ptcp.idfversion(idf)[source]
-
zeppy.ptcp.ipc_parallelpipe(func, args_list, nworkers=None, verbose=False, sleeptime=0.1)[source]
distributed run of the func using zmq
Returns the results of all the run
Uses IPC
-
zeppy.ptcp.make_options(idf)[source]
-
zeppy.ptcp.measure(func)[source]
-
zeppy.ptcp.randstr(strlength)[source]
return a string of length strlength
-
zeppy.ptcp.runeverything()[source]
-
zeppy.ptcp.tcp_parallelpipe(func, args_list, nworkers=None, verbose=False, sleeptime=0.1)[source]
distributed run of the func using zmq
Returns the results of all the run
Uses TCP
-
zeppy.ptcp.wait_add(first, second)[source]
wait for the sum of first and second. return the sum
-
zeppy.ptcp.wait_add_mult(first, add=0, mult=1)[source]
calculate the result=(first+add)*mult. Then waitsome(result)
-
zeppy.ptcp.waitsome(seconds)[source]
wait for some seconds
zeppy.zeppy module
Main module.
Module contents
Top-level package for zeppy.