ManageProcessusEcpi

class ManageProcessusEcpi

Bases: object

manage:

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

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

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

Attributes Summary

instance

Methods Summary

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_run()
nb_pipeline_running()	Return number of running processes.
submit_ecpi(f_pars)	Submit jobs to ECPI
update_status_pipeline()
whoiam()

Attributes Documentation

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

Methods Documentation

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_run()

nb_pipeline_running()

Return number of running processes.

submit_ecpi(f_pars)

Submit jobs to ECPI

update_status_pipeline()

whoiam()