punchpipe.flows.level1

Attributes

SCIENCE_LEVEL0_TYPE_CODES
SCIENCE_LEVEL1_LATE_INPUT_TYPE_CODES
SCIENCE_LEVEL1_LATE_OUTPUT_TYPE_CODES
SCIENCE_LEVEL1_QUICK_INPUT_TYPE_CODES
SCIENCE_LEVEL1_QUICK_OUTPUT_TYPE_CODES
VIGNETTING_CORRESPONDING_TYPES
PSF_MODEL_CORRESPONDING_TYPES
STRAY_LIGHT_CORRESPONDING_TYPES

Functions

level1_early_query_ready_files(session, pipeline_config)
get_distortion_paths(level0_files, pipeline_config[, ...])
get_distortion_path(level0_file, pipeline_config[, ...])
get_vignetting_function_paths(level0_files, ...[, session])
get_vignetting_function_path(level0_file, pipeline_config)
get_psf_model_paths(level0_files, pipeline_config[, ...])
get_psf_model_path(→ str)
get_two_closest_stray_light(level0_file[, session, ...])
get_two_best_stray_light(level0_file[, session])
get_first_last_stray_light(session)
get_quartic_model_paths(level0_files, pipeline_config)
get_quartic_model_path(level0_file, pipeline_config[, ...])
get_mask_files(level0_files, pipeline_config[, session])
get_mask_file(level0_file, pipeline_config[, session, ...])
get_ccd_parameters(level0_file, pipeline_config[, session])
level1_early_construct_flow_info(level0_files, ...[, ...])
level1_early_construct_file_info(...)
level1_early_scheduler_flow([pipeline_config_path, ...])
level1_early_call_data_processor(→ dict)
level1_early_process_flow(flow_id[, ...])
level1_late_query_ready_files(session, pipeline_config)
level1_late_construct_flow_info(input_files, ...[, ...])
level1_late_construct_file_info(...)
level1_late_scheduler_flow([pipeline_config_path, ...])
level1_late_call_data_processor(→ dict)
level1_late_process_flow(flow_id[, ...])
level1_quick_query_ready_files(session, pipeline_config)
level1_quick_construct_flow_info(input_files, ...[, ...])
level1_quick_construct_file_info(...)
level1_quick_scheduler_flow([pipeline_config_path, ...])
level1_quick_call_data_processor(→ dict)
level1_quick_process_flow(flow_id[, ...])

Module Contents

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

punchpipe.flows.level1.SCIENCE_LEVEL1_LATE_INPUT_TYPE_CODES = ['XM', 'XZ', 'XP', 'XR']

punchpipe.flows.level1.SCIENCE_LEVEL1_LATE_OUTPUT_TYPE_CODES = ['PM', 'PZ', 'PP', 'CR']

punchpipe.flows.level1.SCIENCE_LEVEL1_QUICK_INPUT_TYPE_CODES = ['XR']

punchpipe.flows.level1.SCIENCE_LEVEL1_QUICK_OUTPUT_TYPE_CODES = ['QR']

punchpipe.flows.level1.level1_early_query_ready_files(session, pipeline_config: dict, reference_time=None, max_n=9e+99)

punchpipe.flows.level1.get_distortion_paths(level0_files, pipeline_config: dict, session=None)

punchpipe.flows.level1.get_distortion_path(level0_file, pipeline_config: dict, session=None, reference_time=None)

punchpipe.flows.level1.VIGNETTING_CORRESPONDING_TYPES

punchpipe.flows.level1.get_vignetting_function_paths(level0_files, pipeline_config: dict, session=None)

punchpipe.flows.level1.get_vignetting_function_path(level0_file, pipeline_config: dict, session=None, reference_time=None)

punchpipe.flows.level1.PSF_MODEL_CORRESPONDING_TYPES

punchpipe.flows.level1.get_psf_model_paths(level0_files, pipeline_config: dict, session=None)

punchpipe.flows.level1.get_psf_model_path(level0_file, pipeline_config: dict, session=None, reference_time=None) → str

punchpipe.flows.level1.STRAY_LIGHT_CORRESPONDING_TYPES

punchpipe.flows.level1.get_two_closest_stray_light(level0_file, session=None, max_distance: datetime.timedelta = None)

punchpipe.flows.level1.get_two_best_stray_light(level0_file, session=None)

punchpipe.flows.level1.get_first_last_stray_light(session)

punchpipe.flows.level1.get_quartic_model_paths(level0_files, pipeline_config: dict, session=None)

punchpipe.flows.level1.get_quartic_model_path(level0_file, pipeline_config: dict, session=None, reference_time=None)

punchpipe.flows.level1.get_mask_files(level0_files, pipeline_config: dict, session=None)

punchpipe.flows.level1.get_mask_file(level0_file, pipeline_config: dict, session=None, reference_time=None)

punchpipe.flows.level1.get_ccd_parameters(level0_file, pipeline_config: dict, session=None)

punchpipe.flows.level1.level1_early_construct_flow_info(level0_files: list[punchpipe.control.db.File], level1_files: list[punchpipe.control.db.File], pipeline_config: dict, session=None, reference_time=None)

punchpipe.flows.level1.level1_early_construct_file_info(level0_files: List[punchpipe.control.db.File], pipeline_config: dict, reference_time=None) → List[punchpipe.control.db.File]

punchpipe.flows.level1.level1_early_scheduler_flow(pipeline_config_path=None, session=None, reference_time=None)

punchpipe.flows.level1.level1_early_call_data_processor(call_data: dict, pipeline_config, session=None) → dict

punchpipe.flows.level1.level1_early_process_flow(flow_id: int | list[int], pipeline_config_path=None, session=None)

punchpipe.flows.level1.level1_late_query_ready_files(session, pipeline_config: dict, reference_time=None, max_n=9e+99)

punchpipe.flows.level1.level1_late_construct_flow_info(input_files: list[punchpipe.control.db.File], output_files: list[punchpipe.control.db.File], pipeline_config: dict, session=None, reference_time=None)

punchpipe.flows.level1.level1_late_construct_file_info(input_files: List[punchpipe.control.db.File], pipeline_config: dict, reference_time=None) → List[punchpipe.control.db.File]

punchpipe.flows.level1.level1_late_scheduler_flow(pipeline_config_path=None, session=None, reference_time=None)

punchpipe.flows.level1.level1_late_call_data_processor(call_data: dict, pipeline_config, session=None) → dict

punchpipe.flows.level1.level1_late_process_flow(flow_id: int | list[int], pipeline_config_path=None, session=None)

punchpipe.flows.level1.level1_quick_query_ready_files(session, pipeline_config: dict, reference_time=None, max_n=9e+99)

punchpipe.flows.level1.level1_quick_construct_flow_info(input_files: list[punchpipe.control.db.File], output_files: list[punchpipe.control.db.File], pipeline_config: dict, session=None, reference_time=None)

punchpipe.flows.level1.level1_quick_construct_file_info(input_files: List[punchpipe.control.db.File], pipeline_config: dict, reference_time=None) → List[punchpipe.control.db.File]

punchpipe.flows.level1.level1_quick_scheduler_flow(pipeline_config_path=None, session=None, reference_time=None)

punchpipe.flows.level1.level1_quick_call_data_processor(call_data: dict, pipeline_config, session=None) → dict

punchpipe.flows.level1.level1_quick_process_flow(flow_id: int | list[int], pipeline_config_path=None, session=None)