punchpipe.flows.levelh#

Attributes#

SCIENCE_LEVEL0_TYPE_CODES

Functions#

`levelh_query_ready_files`(session, pipeline_config[, ...])
`levelh_construct_flow_info`(level0_files, level1_files, ...)
`levelh_construct_file_info`(...)
`levelh_scheduler_flow`([pipeline_config_path, session, ...])
`levelh_call_data_processor`(→ dict)
`levelh_process_flow`(flow_id[, pipeline_config_path, ...])

Module Contents#

punchpipe.flows.levelh.SCIENCE_LEVEL0_TYPE_CODES = ['PM', 'PZ', 'PP', 'CR']#

punchpipe.flows.levelh.levelh_query_ready_files(session, pipeline_config: dict, reference_time=None, max_n=9e+99)[source]#

punchpipe.flows.levelh.levelh_construct_flow_info(level0_files: list[punchpipe.control.db.File], level1_files: punchpipe.control.db.File, pipeline_config: dict, session=None, reference_time=None)[source]#

punchpipe.flows.levelh.levelh_construct_file_info(level0_files: List[punchpipe.control.db.File], pipeline_config: dict, reference_time=None) → List[punchpipe.control.db.File][source]#

punchpipe.flows.levelh.levelh_scheduler_flow(pipeline_config_path=None, session=None, reference_time=None)[source]#

punchpipe.flows.levelh.levelh_call_data_processor(call_data: dict, pipeline_config, session=None) → dict[source]#

punchpipe.flows.levelh.levelh_process_flow(flow_id: int, pipeline_config_path=None, session=None)[source]#