ManageProcessusEcpi

class ManageProcessusEcpi

Bases: object

manage:

• start processing
• update status processing with thread timer or status request
• nats message associated processing

#TODO: manage process finished keep 100 last ? before i month ?

@author: Colley Jean-Marc, APC/IN2P3/CNRS

submit_process used singleton design pattern, ie only one instance of class ManageProcessusEcpi

Attributes Summary

instance

Methods Summary

get_all_name_proc()
get_exit_message(process_name)
get_exit_value(process_name)
init_nats(nats)
is_running(p_id)
is_valid_proc_name(proc_name)
nb_pipeline_done()
nb_pipeline_running()	Return number of running processes.
submit_ecpi(f_pars)	Submit process ECPI
submit_process(p_func, p_params)	Submit p_func(p_params) in processpro
update_status_pipeline()
whoiam()

Attributes Documentation

instance = <ecpi.process.server.manage_pipeline.ManageProcessusEcpi object>

Methods Documentation

get_all_name_proc()

get_exit_message(process_name)

get_exit_value(process_name)

init_nats(nats)

is_running(p_id)

is_valid_proc_name(proc_name)

nb_pipeline_done()

nb_pipeline_running()

Return number of running processes.

submit_ecpi(f_pars)

Submit process ECPI

submit_process(p_func, p_params)

Submit p_func(p_params) in processpro

update_status_pipeline()

whoiam()