punchpipe.flows.stray_light

Functions

construct_clear_stray_light_check_for_inputs(session, ...)
construct_polarized_stray_light_check_for_inputs(...)
construct_stray_light_flow_info(level1_files, ...[, ...])
construct_stray_light_file_info(...)
construct_stray_light_scheduler_flow([...])
construct_stray_light_call_data_processor(→ dict)
construct_stray_light_process_flow(flow_id[, ...])
call_correct_stray_light_function(*args, **kwargs)

Module Contents

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

punchpipe.flows.stray_light.construct_polarized_stray_light_check_for_inputs(session, pipeline_config: dict, reference_time: datetime.datetime, reference_files: list[punchpipe.control.db.File])

punchpipe.flows.stray_light.construct_stray_light_flow_info(level1_files: list[punchpipe.control.db.File], level1_stray_light_files: punchpipe.control.db.File, pipeline_config: dict, reference_time: datetime.datetime, file_type: str, spacecraft: str, session=None)

punchpipe.flows.stray_light.construct_stray_light_file_info(level1_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.stray_light.construct_stray_light_scheduler_flow(pipeline_config_path=None, session=None, reference_time: datetime.datetime | None = None)

punchpipe.flows.stray_light.construct_stray_light_call_data_processor(call_data: dict, pipeline_config, session) → dict

punchpipe.flows.stray_light.construct_stray_light_process_flow(flow_id: int, pipeline_config_path=None, session=None)

punchpipe.flows.stray_light.call_correct_stray_light_function(*args, **kwargs)