ecpi.process.server.manage_pipeline Module

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

Functions

add_path_process_eclairs(p_file) add to p_file the path of the ECLAIRs processing directory.
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
return_level(file) Return logger level from file parameters ecpi, ie key logger_level in section general
timer_nats(manager) Set NATS messaging period to 60s.
timer_update_status(manager) Update pipeline status.

Classes

ECPILogger([log_level, log_dest_path, …]) Logger for ECPI
EclairsPipelineForHttpServer(cfg_path[, id_proc]) ECLAIRs pipeline in HTTP server mode
EclairsQlaLevel1(target[, id_proc]) QLA level 1 ECPI
ManageProcessusEcpi() manage:
MessagingFSCnone @author: Colley Jean-Marc, APC/IN2P3/CNRS

Class diagram

_images/classes_ecpi.process.server.manage_pipeline.png