punchpipe.flows.fcorona

Functions

f_corona_background_query_ready_files(session, ...)
construct_f_corona_background_flow_info(level3_files, ...)
construct_f_corona_background_file_info(...)
construct_f_corona_background_scheduler_flow([...])
construct_f_corona_call_data_processor(→ dict)
construct_f_corona_background_process_flow(flow_id[, ...])

Module Contents

punchpipe.flows.fcorona.f_corona_background_query_ready_files(session, pipeline_config: dict, reference_time: datetime.datetime, reference_file: punchpipe.control.db.File)

punchpipe.flows.fcorona.construct_f_corona_background_flow_info(level3_files: list[punchpipe.control.db.File], level3_f_model_file: [punchpipe.control.db.File], pipeline_config: dict, reference_time: datetime.datetime, file_type: str, spacecraft: str, session=None)

punchpipe.flows.fcorona.construct_f_corona_background_file_info(level2_files: List[punchpipe.control.db.File], pipeline_config: dict, reference_time: datetime.datetime, file_type: str, spacecraft: str) → List[punchpipe.control.db.File]

punchpipe.flows.fcorona.construct_f_corona_background_scheduler_flow(pipeline_config_path=None, session=None, reference_time: datetime.datetime | None = None)

punchpipe.flows.fcorona.construct_f_corona_call_data_processor(call_data: dict, pipeline_config, session=None) → dict

punchpipe.flows.fcorona.construct_f_corona_background_process_flow(flow_id: int, pipeline_config_path=None, session=None)