ecpi.server.manage_pipeline module

Section author: ECLAIRs GP team

Management of processing submit on HTTP ECPI server

Summary

Classes:

ManageProcessusEcpi	manage:
MessagingFSCnone	Interface for messaging handle

Class diagram:

Functions:

dummy_ecpi	Dummy ECPI for testing.
get_upload_path	Getter for upload path
process_ecpi	Process ECPI for given ID.
process_qla_level1	launch QLA level 1 pipeline
timer_nats	Set NATS messaging period to 60s.
timer_update_status	Update pipeline status.

Reference

class ManageProcessusEcpi(*args, **kargs)

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 ?

get_all_name_proc()

get_exit_message(process_name)

get_exit_value(process_name)

init_nats(nats)

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

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

class MessagingFSCnone

Bases: object

Interface for messaging handle

publish_ecpi_end(proc_id, error_code, error_message)

publish_ecpi_start(proc_id)

publish_periodic_status()

publish_server_start()

dummy_ecpi(id_process, f_pars, p_queue)

Dummy ECPI for testing.

get_upload_path()

Getter for upload path

process_ecpi(id_process, f_pars, p_queue)

Process ECPI for given ID.

process_qla_level1(id_process, params, p_queue)

launch QLA level 1 pipeline

Parameters

• id_process –

• params –

• p_queue –

timer_nats(manager)

Set NATS messaging period to 60s.

timer_update_status(manager)

Update pipeline status.