punchpipe.flows.level3#

Functions#

get_valid_starfields(session, f, timedelta_window[, ...])

get_valid_fcorona_models(session, f, before_timedelta, ...)

level3_PTM_query_ready_files(session, pipeline_config)

level3_PTM_construct_flow_info(level2_files, ...[, ...])

level3_PTM_construct_file_info(...)

level3_PTM_scheduler_flow([pipeline_config_path, ...])

level3_PTM_call_data_processor(→ dict)

level3_PTM_process_flow(flow_id[, ...])

level3_PIM_query_ready_files(session, pipeline_config)

level3_PIM_construct_flow_info(level2_files, ...[, ...])

level3_PIM_construct_file_info(...)

level3_PIM_scheduler_flow([pipeline_config_path, ...])

level3_PIM_call_data_processor(→ dict)

level3_PIM_process_flow(flow_id[, ...])

level3_CIM_query_ready_files(session, pipeline_config)

level3_CIM_construct_flow_info(level2_files, ...[, ...])

level3_CIM_construct_file_info(...)

level3_CIM_scheduler_flow([pipeline_config_path, ...])

level3_CIM_call_data_processor(→ dict)

level3_CIM_process_flow(flow_id[, ...])

level3_CTM_query_ready_files(session, pipeline_config)

level3_CTM_construct_flow_info(level2_files, ...[, ...])

level3_CTM_construct_file_info(...)

level3_CTM_scheduler_flow([pipeline_config_path, ...])

level3_CTM_call_data_processor(→ dict)

level3_CTM_process_flow(flow_id[, ...])

Module Contents#

punchpipe.flows.level3.get_valid_starfields(session, f: punchpipe.control.db.File, timedelta_window: datetime.timedelta, file_type: str = 'PS')[source]#
punchpipe.flows.level3.get_valid_fcorona_models(session, f: punchpipe.control.db.File, before_timedelta: datetime.timedelta, after_timedelta: datetime.timedelta, file_type='PF')[source]#
punchpipe.flows.level3.level3_PTM_query_ready_files(session, pipeline_config: dict, reference_time=None, max_n=9e+99)[source]#
punchpipe.flows.level3.level3_PTM_construct_flow_info(level2_files: list[punchpipe.control.db.File], level3_file: punchpipe.control.db.File, pipeline_config: dict, session=None, reference_time=None)[source]#
punchpipe.flows.level3.level3_PTM_construct_file_info(input_files: List[punchpipe.control.db.File], pipeline_config: dict, reference_time=None) → List[punchpipe.control.db.File][source]#
punchpipe.flows.level3.level3_PTM_scheduler_flow(pipeline_config_path=None, session=None, reference_time=None)[source]#
punchpipe.flows.level3.level3_PTM_call_data_processor(call_data: dict, pipeline_config, session=None) → dict[source]#
punchpipe.flows.level3.level3_PTM_process_flow(flow_id: int | list[int], pipeline_config_path=None, session=None)[source]#
punchpipe.flows.level3.level3_PIM_query_ready_files(session, pipeline_config: dict, reference_time=None, max_n=9e+99)[source]#
punchpipe.flows.level3.level3_PIM_construct_flow_info(level2_files: list[punchpipe.control.db.File], level3_file: punchpipe.control.db.File, pipeline_config: dict, session=None, reference_time=None)[source]#
punchpipe.flows.level3.level3_PIM_construct_file_info(level2_files: List[punchpipe.control.db.File], pipeline_config: dict, reference_time=None) → List[punchpipe.control.db.File][source]#
punchpipe.flows.level3.level3_PIM_scheduler_flow(pipeline_config_path: str | None = None, session=None, reference_time: datetime.datetime | None = None)[source]#
punchpipe.flows.level3.level3_PIM_call_data_processor(call_data: dict, pipeline_config, session=None) → dict[source]#
punchpipe.flows.level3.level3_PIM_process_flow(flow_id: int | list[int], pipeline_config_path=None, session=None)[source]#
punchpipe.flows.level3.level3_CIM_query_ready_files(session, pipeline_config: dict, reference_time=None, max_n=9e+99)[source]#
punchpipe.flows.level3.level3_CIM_construct_flow_info(level2_files: list[punchpipe.control.db.File], level3_file: punchpipe.control.db.File, pipeline_config: dict, session=None, reference_time=None)[source]#
punchpipe.flows.level3.level3_CIM_construct_file_info(level2_files: List[punchpipe.control.db.File], pipeline_config: dict, reference_time=None) → List[punchpipe.control.db.File][source]#
punchpipe.flows.level3.level3_CIM_scheduler_flow(pipeline_config_path: str | None = None, session=None, reference_time: datetime.datetime | None = None)[source]#
punchpipe.flows.level3.level3_CIM_call_data_processor(call_data: dict, pipeline_config, session=None) → dict[source]#
punchpipe.flows.level3.level3_CIM_process_flow(flow_id: int | list[int], pipeline_config_path=None, session=None)[source]#
punchpipe.flows.level3.level3_CTM_query_ready_files(session, pipeline_config: dict, reference_time=None, max_n=9e+99)[source]#
punchpipe.flows.level3.level3_CTM_construct_flow_info(level2_files: list[punchpipe.control.db.File], level3_file: punchpipe.control.db.File, pipeline_config: dict, session=None, reference_time=None)[source]#
punchpipe.flows.level3.level3_CTM_construct_file_info(input_files: List[punchpipe.control.db.File], pipeline_config: dict, reference_time=None) → List[punchpipe.control.db.File][source]#
punchpipe.flows.level3.level3_CTM_scheduler_flow(pipeline_config_path=None, session=None, reference_time=None)[source]#
punchpipe.flows.level3.level3_CTM_call_data_processor(call_data: dict, pipeline_config, session=None) → dict[source]#
punchpipe.flows.level3.level3_CTM_process_flow(flow_id: int | list[int], pipeline_config_path=None, session=None)[source]#