punchpipe.flows.starfield

Functions

starfield_background_query_ready_files(session, ...)
construct_starfield_background_flow_info(...[, session])
construct_starfield_background_file_info(...)
construct_starfield_background_scheduler_flow([...])
construct_starfield_call_data_processor(→ dict)
construct_starfield_background_process_flow(flow_id[, ...])

Module Contents

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

punchpipe.flows.starfield.construct_starfield_background_flow_info(level3_fcorona_subtracted_files: list[punchpipe.control.db.File], level3_starfield_model_file: [punchpipe.control.db.File], pipeline_config: dict, reference_time: datetime.datetime, file_type: str, spacecraft: str, session=None)

punchpipe.flows.starfield.construct_starfield_background_file_info(level3_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.starfield.construct_starfield_background_scheduler_flow(pipeline_config_path=None, session=None, reference_time: datetime.datetime | None = None)

punchpipe.flows.starfield.construct_starfield_call_data_processor(call_data: dict, pipeline_config, session=None) → dict

punchpipe.flows.starfield.construct_starfield_background_process_flow(flow_id: int, pipeline_config_path=None, session=None)