Index

_

__repr__() (punchpipe.control.cache_layer.loader_base_class.LoaderABC method) (punchpipe.control.cache_layer.nfi_l1.NFIL1Loader method) (punchpipe.control.cache_layer.psf.PSFLoader method) (punchpipe.control.cache_layer.quartic_coefficients.QuarticLoader method) (punchpipe.control.cache_layer.stray_light.StrayLightLoader method) (punchpipe.control.cache_layer.vignetting_function.VignettingLoader method) (punchpipe.control.db.File method) (punchpipe.control.db.Flow method) (punchpipe.control.tests.File method) (punchpipe.flows.level0.TLMLoader method) __str__() (punchpipe.control.cache_layer.loader_base_class.LoaderABC method) __tablename__ (punchpipe.control.db.ENG_CEB attribute) (punchpipe.control.db.ENG_LED attribute) (punchpipe.control.db.ENG_LZ attribute) (punchpipe.control.db.ENG_PFW attribute) (punchpipe.control.db.ENG_XACT attribute) (punchpipe.control.db.File attribute) (punchpipe.control.db.FileRelationship attribute) (punchpipe.control.db.Flow attribute) (punchpipe.control.db.Health attribute) (punchpipe.control.db.PacketHistory attribute) (punchpipe.control.db.SCI_XFI attribute) (punchpipe.control.db.TLMFiles attribute) (punchpipe.control.tests.File attribute)

__version__ (in module punchpipe) _level2_query_ready_files() (in module punchpipe.flows.level2) _since (punchpipe.flows.level0.TaiDatetimeConverter attribute) _units (punchpipe.flows.level0.TaiDatetimeConverter attribute)

A

acquisition_settings (punchpipe.control.db.SCI_XFI attribute)

apid_name2num (punchpipe.flows.level0.TLMLoader attribute) app (in module punchpipe.monitor.app)

B

bad_packets (punchpipe.control.db.File attribute) (punchpipe.control.tests.File attribute)

Base (in module punchpipe.control.db) batched() (in module punchpipe.control.util)

C

CACHE_KEY_PREFIX (in module punchpipe.control.cache_layer.manager) cache_nanny() (in module punchpipe.control.cache_nanny) caching_is_enabled() (in module punchpipe.control.cache_layer.manager) call_correct_stray_light_function() (in module punchpipe.flows.stray_light) call_data (punchpipe.control.db.Flow attribute) cancel_running_prefect_flows_before_cutoff() (in module punchpipe.control.cleaner) ccsds_packet_length (punchpipe.control.db.ENG_CEB attribute) (punchpipe.control.db.ENG_LED attribute) (punchpipe.control.db.ENG_LZ attribute) (punchpipe.control.db.ENG_PFW attribute) (punchpipe.control.db.ENG_XACT attribute) (punchpipe.control.db.SCI_XFI attribute) ccsds_sequence_count (punchpipe.control.db.ENG_CEB attribute) (punchpipe.control.db.ENG_LED attribute) (punchpipe.control.db.ENG_LZ attribute) (punchpipe.control.db.ENG_PFW attribute) (punchpipe.control.db.ENG_XACT attribute) (punchpipe.control.db.SCI_XFI attribute) CCSDSPacketConstructionWarning CCSDSPacketDatabaseUpdateWarning child (punchpipe.control.db.FileRelationship attribute) clean_replay() (in module punchpipe.cli) cleaner() (in module punchpipe.control.cleaner) collect_pairs_by_phase() (in module punchpipe.flows.dynamic_wfi_stray_light) column_names (in module home) compression_settings (punchpipe.control.db.SCI_XFI attribute) CONFIG_PATH (in module punchpipe.flows.tests.test_replay) construct_base_query() (in module files) construct_clear_stray_light_check_for_inputs() (in module punchpipe.flows.stray_light) construct_dynamic_stray_light_call_data_processor() (in module punchpipe.flows.dynamic_wfi_stray_light) construct_dynamic_stray_light_check_for_inputs() (in module punchpipe.flows.dynamic_wfi_stray_light) construct_dynamic_stray_light_file_info() (in module punchpipe.flows.dynamic_wfi_stray_light) construct_dynamic_stray_light_flow_info() (in module punchpipe.flows.dynamic_wfi_stray_light)

construct_dynamic_stray_light_process_flow() (in module punchpipe.flows.dynamic_wfi_stray_light) construct_dynamic_stray_light_scheduler_flow() (in module punchpipe.flows.dynamic_wfi_stray_light) construct_f_corona_background_file_info() (in module punchpipe.flows.fcorona) construct_f_corona_background_flow_info() (in module punchpipe.flows.fcorona) construct_f_corona_background_process_flow() (in module punchpipe.flows.fcorona) construct_f_corona_background_scheduler_flow() (in module punchpipe.flows.fcorona) construct_f_corona_call_data_processor() (in module punchpipe.flows.fcorona) construct_flows_to_serve() (in module punchpipe.cli) construct_levelq_CFM_file_info() (in module punchpipe.flows.levelq) construct_levelq_CFM_flow_info() (in module punchpipe.flows.levelq) construct_levelq_CFN_background_file_info() (in module punchpipe.flows.levelq) construct_levelq_CFN_flow_info() (in module punchpipe.flows.levelq) construct_polarized_stray_light_check_for_inputs() (in module punchpipe.flows.stray_light) construct_starfield_background_file_info() (in module punchpipe.flows.starfield) construct_starfield_background_flow_info() (in module punchpipe.flows.starfield) construct_starfield_background_process_flow() (in module punchpipe.flows.starfield) construct_starfield_background_scheduler_flow() (in module punchpipe.flows.starfield) construct_starfield_call_data_processor() (in module punchpipe.flows.starfield) construct_stray_light_call_data_processor() (in module punchpipe.flows.stray_light) construct_stray_light_file_info() (in module punchpipe.flows.stray_light) construct_stray_light_flow_info() (in module punchpipe.flows.stray_light) construct_stray_light_process_flow() (in module punchpipe.flows.stray_light) construct_stray_light_scheduler_flow() (in module punchpipe.flows.stray_light) convert() (punchpipe.flows.level0.TaiDatetimeConverter method) count_flows() (in module punchpipe.control.launcher) cpu_usage (punchpipe.control.db.Health attribute) create_app() (in module punchpipe.monitor.app) create_card_content() (in module home) create_file_card_content() (in module home) create_packet_definitions() (in module punchpipe.flows.level0) creation_time (punchpipe.control.db.Flow attribute) credentials (in module punchpipe.flows.level0) crota (punchpipe.control.db.File attribute) (punchpipe.control.tests.File attribute)

D

data (punchpipe.control.cache_layer.manager.ExportableWrapper attribute) date_beg (punchpipe.control.db.File attribute) (punchpipe.control.tests.File attribute) date_created (punchpipe.control.db.File attribute) (punchpipe.control.tests.File attribute) date_end (punchpipe.control.db.File attribute) (punchpipe.control.tests.File attribute) date_obs (punchpipe.control.db.File attribute) (punchpipe.control.tests.File attribute) datetime (punchpipe.control.db.Health attribute) (punchpipe.control.db.PacketHistory attribute) db (in module punchpipe.control.tests.test_cleaner) (in module punchpipe.control.tests.test_launcher) (in module punchpipe.control.tests.test_processor) (in module punchpipe.flows.tests.test_level1) (in module punchpipe.flows.tests.test_level2) (in module punchpipe.flows.tests.test_levelQ)

db_empty (in module punchpipe.control.tests.test_launcher) (in module punchpipe.control.tests.test_processor) db_out_exists (in module punchpipe.control.tests.test_processor) db_to_utime() (in module punchpipe.flows.dynamic_wfi_stray_light) decode_image_packets() (in module punchpipe.flows.level0) DEFAULT_SCALING (in module punchpipe.control.util) defs (punchpipe.flows.level0.TLMLoader attribute) detect_new_tlm_files() (in module punchpipe.flows.level0) determine_file_type() (in module punchpipe.flows.level0) determine_launchable_flow_count() (in module punchpipe.control.launcher) directory() (punchpipe.control.db.File method) (punchpipe.control.tests.File method) disk_percentage (punchpipe.control.db.Health attribute) disk_usage (punchpipe.control.db.Health attribute) DYNAMIC_STRAY_LIGHT_CORRESPONDING_TYPES (in module punchpipe.flows.level1)

E

eci_quaternion_to_ra_dec() (in module punchpipe.flows.level0) empty_core_flow() (in module punchpipe.control.tests.test_processor) empty_flow() (in module punchpipe.control.tests.test_processor) end_time (punchpipe.control.db.Flow attribute) ENG_CEB (class in punchpipe.control.db) ENG_LED (class in punchpipe.control.db)

ENG_LZ (class in punchpipe.control.db) ENG_PFW (class in punchpipe.control.db) ENG_XACT (class in punchpipe.control.db) engine (in module punchpipe.flows.level0) escalate_long_waiting_flows() (in module punchpipe.control.launcher) ExportableWrapper (class in punchpipe.control.cache_layer.manager)

F

f_corona_background_query_ready_files() (in module punchpipe.flows.fcorona) fail_stuck_flows() (in module punchpipe.control.cleaner) fiducial_utime (in module punchpipe.flows.dynamic_wfi_stray_light) File (class in punchpipe.control.db) (class in punchpipe.control.tests) file_id (punchpipe.control.db.File attribute) (punchpipe.control.tests.File attribute) file_name_to_full_path() (in module punchpipe.flows.util) file_type (punchpipe.control.db.File attribute) (punchpipe.control.tests.File attribute) file_version (punchpipe.control.db.File attribute) (punchpipe.control.tests.File attribute) filename() (punchpipe.control.db.File method) (punchpipe.control.tests.File method) FileRelationship (class in punchpipe.control.db) files module

find_flow() (in module punchpipe.cli) FIXED_PACKETS (in module punchpipe.flows.level0) flash_block (punchpipe.control.db.SCI_XFI attribute) Flow (class in punchpipe.control.db) flow_batch_sizes() (in module punchpipe.control.tests.test_launcher) flow_id (punchpipe.control.db.Flow attribute) flow_level (punchpipe.control.db.Flow attribute) flow_run_id (punchpipe.control.db.Flow attribute) flow_run_name (punchpipe.control.db.Flow attribute) flow_type (punchpipe.control.db.Flow attribute) flow_weights() (in module punchpipe.control.tests.test_launcher) form_preliminary_wcs() (in module punchpipe.flows.level0) form_single_image() (in module punchpipe.flows.level0) form_single_image_caller() (in module punchpipe.flows.level0) from_bytes() (punchpipe.control.cache_layer.loader_base_class.LoaderABC method)

G

gather_planned_flows() (in module punchpipe.control.launcher) (in module punchpipe.speedster) gen_key() (punchpipe.control.cache_layer.loader_base_class.LoaderABC method) (punchpipe.control.cache_layer.nfi_l1.NFIL1Loader method) (punchpipe.control.cache_layer.psf.PSFLoader method) (punchpipe.control.cache_layer.quartic_coefficients.QuarticLoader method) (punchpipe.control.cache_layer.stray_light.StrayLightLoader method) (punchpipe.control.cache_layer.vignetting_function.VignettingLoader method) (punchpipe.flows.level0.TLMLoader method) generate_flow_run_name() (in module punchpipe.flows.visualize) generic_process_flow_logic() (in module punchpipe.control.processor) generic_scheduler_flow_logic() (in module punchpipe.control.scheduler) get_ccd_parameters() (in module punchpipe.flows.level1) get_ccsds_data_type() (in module punchpipe.flows.level0) get_closest_after_file() (in module punchpipe.control.db) get_closest_before_file() (in module punchpipe.control.db) get_closest_file() (in module punchpipe.control.db) get_database_session() (in module punchpipe.control.util) (in module punchpipe.monitor.app) get_distortion_path() (in module punchpipe.flows.level1) get_distortion_paths() (in module punchpipe.flows.level1) get_existing_cache_files() (in module punchpipe.control.cache_layer.manager)

get_fcorona_models() (in module punchpipe.flows.levelq) get_files_in_time_window() (in module punchpipe.control.util) get_first_last_stray_light() (in module punchpipe.flows.level1) get_mask_file() (in module punchpipe.flows.level1) get_mask_files() (in module punchpipe.flows.level1) get_mask_paths() (in module punchpipe.flows.level0) get_metadata() (in module punchpipe.flows.level0) get_outlier_limits_paths() (in module punchpipe.flows.level0) get_polarization_sequence() (in module punchpipe.flows.level1) get_psf_model_path() (in module punchpipe.flows.level1) get_psf_model_paths() (in module punchpipe.flows.level1) get_quartic_model_path() (in module punchpipe.flows.level1) get_quartic_model_paths() (in module punchpipe.flows.level1) get_two_best_stray_light() (in module punchpipe.flows.level1) get_two_closest_stray_light() (in module punchpipe.flows.level1) get_valid_fcorona_models() (in module punchpipe.flows.level3) get_valid_starfields() (in module punchpipe.flows.level3) get_vignetting_function_path() (in module punchpipe.flows.level1) get_vignetting_function_paths() (in module punchpipe.flows.level1) group_files_by_time() (in module punchpipe.control.util) group_l2_inputs() (in module punchpipe.flows.level2) group_l2_inputs_single_observatory() (in module punchpipe.flows.level2)

H

Health (class in punchpipe.control.db) health_id (punchpipe.control.db.Health attribute)

health_monitor() (in module punchpipe.control.health) home module

I

id (punchpipe.control.db.ENG_CEB attribute) (punchpipe.control.db.ENG_LED attribute) (punchpipe.control.db.ENG_LZ attribute) (punchpipe.control.db.ENG_PFW attribute) (punchpipe.control.db.ENG_XACT attribute) (punchpipe.control.db.PacketHistory attribute) (punchpipe.control.db.SCI_XFI attribute)

ingest_tlm_file() (in module punchpipe.flows.level0) initializer() (in module punchpipe.flows.level0) is_backprocessing (punchpipe.control.db.Flow attribute) is_used (punchpipe.control.db.SCI_XFI attribute)

L

last_attempt (punchpipe.control.db.SCI_XFI attribute) (punchpipe.control.db.TLMFiles attribute) last_skip_reason (punchpipe.control.db.SCI_XFI attribute) launch_ready_flows() (in module punchpipe.control.launcher) launch_time (punchpipe.control.db.Flow attribute) launcher() (in module punchpipe.control.launcher) layout() (in module files) (in module home) led_end_time (punchpipe.control.db.ENG_LED attribute) led_start_time (punchpipe.control.db.ENG_LED attribute) level (punchpipe.control.db.File attribute) (punchpipe.control.tests.File attribute) level0_construct_flow_info() (in module punchpipe.flows.level0) level0_core_flow() (in module punchpipe.flows.level0) level0_form_images() (in module punchpipe.flows.level0) level0_process_flow() (in module punchpipe.flows.level0) level0_scheduler_flow() (in module punchpipe.flows.level0) level1_early_call_data_processor() (in module punchpipe.flows.level1) level1_early_construct_file_info() (in module punchpipe.flows.level1) level1_early_construct_flow_info() (in module punchpipe.flows.level1) level1_early_process_flow() (in module punchpipe.flows.level1) level1_early_query_ready_files() (in module punchpipe.flows.level1) level1_early_scheduler_flow() (in module punchpipe.flows.level1) level1_late_call_data_processor() (in module punchpipe.flows.level1) level1_late_construct_file_info() (in module punchpipe.flows.level1) level1_late_construct_flow_info() (in module punchpipe.flows.level1) level1_late_process_flow() (in module punchpipe.flows.level1) level1_late_query_ready_files() (in module punchpipe.flows.level1) level1_late_scheduler_flow() (in module punchpipe.flows.level1) level1_middle_call_data_processor() (in module punchpipe.flows.level1) level1_middle_construct_file_info() (in module punchpipe.flows.level1) level1_middle_construct_flow_info() (in module punchpipe.flows.level1) level1_middle_process_flow() (in module punchpipe.flows.level1) level1_middle_query_ready_files() (in module punchpipe.flows.level1) level1_middle_scheduler_flow() (in module punchpipe.flows.level1) level1_quick_call_data_processor() (in module punchpipe.flows.level1) level1_quick_construct_file_info() (in module punchpipe.flows.level1) level1_quick_construct_flow_info() (in module punchpipe.flows.level1) level1_quick_process_flow() (in module punchpipe.flows.level1) level1_quick_query_ready_files() (in module punchpipe.flows.level1) level1_quick_scheduler_flow() (in module punchpipe.flows.level1) level2_call_data_processor() (in module punchpipe.flows.level2) level2_clear_process_flow() (in module punchpipe.flows.level2) level2_clear_scheduler_flow() (in module punchpipe.flows.level2) level2_construct_file_info() (in module punchpipe.flows.level2) level2_construct_flow_info() (in module punchpipe.flows.level2) level2_process_flow() (in module punchpipe.flows.level2) level2_query_ready_clear_files() (in module punchpipe.flows.level2) level2_query_ready_files() (in module punchpipe.flows.level2) level2_scheduler_flow() (in module punchpipe.flows.level2) level3_CIM_call_data_processor() (in module punchpipe.flows.level3) level3_CIM_construct_file_info() (in module punchpipe.flows.level3) level3_CIM_construct_flow_info() (in module punchpipe.flows.level3) level3_CIM_process_flow() (in module punchpipe.flows.level3) level3_CIM_query_ready_files() (in module punchpipe.flows.level3) level3_CIM_scheduler_flow() (in module punchpipe.flows.level3) level3_CTM_call_data_processor() (in module punchpipe.flows.level3) level3_CTM_construct_file_info() (in module punchpipe.flows.level3) level3_CTM_construct_flow_info() (in module punchpipe.flows.level3) level3_CTM_process_flow() (in module punchpipe.flows.level3) level3_CTM_query_ready_files() (in module punchpipe.flows.level3) level3_CTM_scheduler_flow() (in module punchpipe.flows.level3) level3_PIM_call_data_processor() (in module punchpipe.flows.level3) level3_PIM_construct_file_info() (in module punchpipe.flows.level3) level3_PIM_construct_flow_info() (in module punchpipe.flows.level3) level3_PIM_process_flow() (in module punchpipe.flows.level3) level3_PIM_query_ready_files() (in module punchpipe.flows.level3) level3_PIM_scheduler_flow() (in module punchpipe.flows.level3) level3_PTM_call_data_processor() (in module punchpipe.flows.level3) level3_PTM_construct_file_info() (in module punchpipe.flows.level3)

level3_PTM_construct_flow_info() (in module punchpipe.flows.level3) level3_PTM_process_flow() (in module punchpipe.flows.level3) level3_PTM_query_ready_files() (in module punchpipe.flows.level3) level3_PTM_scheduler_flow() (in module punchpipe.flows.level3) level3_vam_call_data_processor() (in module punchpipe.flows.velocity) level3_vam_construct_file_info() (in module punchpipe.flows.velocity) level3_vam_construct_flow_info() (in module punchpipe.flows.velocity) level3_vam_process_flow() (in module punchpipe.flows.velocity) level3_vam_query_ready_files() (in module punchpipe.flows.velocity) level3_vam_scheduler_flow() (in module punchpipe.flows.velocity) level3_van_call_data_processor() (in module punchpipe.flows.velocity) level3_van_construct_file_info() (in module punchpipe.flows.velocity) level3_van_construct_flow_info() (in module punchpipe.flows.velocity) level3_van_process_flow() (in module punchpipe.flows.velocity) level3_van_query_ready_files() (in module punchpipe.flows.velocity) level3_van_scheduler_flow() (in module punchpipe.flows.velocity) levelh_call_data_processor() (in module punchpipe.flows.levelh) levelh_construct_file_info() (in module punchpipe.flows.levelh) levelh_construct_flow_info() (in module punchpipe.flows.levelh) levelh_process_flow() (in module punchpipe.flows.levelh) levelh_query_ready_files() (in module punchpipe.flows.levelh) levelh_scheduler_flow() (in module punchpipe.flows.levelh) levelq_CFM_call_data_processor() (in module punchpipe.flows.levelq) levelq_CFM_process_flow() (in module punchpipe.flows.levelq) levelq_CFM_query_ready_files() (in module punchpipe.flows.levelq) levelq_CFM_scheduler_flow() (in module punchpipe.flows.levelq) levelq_CFN_call_data_processor() (in module punchpipe.flows.levelq) levelq_CFN_process_flow() (in module punchpipe.flows.levelq) levelq_CFN_query_ready_files() (in module punchpipe.flows.levelq) levelq_CFN_scheduler_flow() (in module punchpipe.flows.levelq) levelq_CNN_call_data_processor() (in module punchpipe.flows.levelq) levelq_CNN_construct_file_info() (in module punchpipe.flows.levelq) levelq_CNN_construct_flow_info() (in module punchpipe.flows.levelq) levelq_CNN_process_flow() (in module punchpipe.flows.levelq) levelq_CNN_query_ready_files() (in module punchpipe.flows.levelq) levelq_CNN_scheduler_flow() (in module punchpipe.flows.levelq) levelq_CQM_call_data_processor() (in module punchpipe.flows.levelq) levelq_CQM_construct_file_info() (in module punchpipe.flows.levelq) levelq_CQM_construct_flow_info() (in module punchpipe.flows.levelq) levelq_CQM_process_flow() (in module punchpipe.flows.levelq) levelq_CQM_query_ready_files() (in module punchpipe.flows.levelq) levelq_CQM_scheduler_flow() (in module punchpipe.flows.levelq) levelq_CTM_call_data_processor() (in module punchpipe.flows.levelq) levelq_CTM_construct_file_info() (in module punchpipe.flows.levelq) levelq_CTM_construct_flow_info() (in module punchpipe.flows.levelq) levelq_CTM_process_flow() (in module punchpipe.flows.levelq) levelq_CTM_query_ready_files() (in module punchpipe.flows.levelq) levelq_CTM_scheduler_flow() (in module punchpipe.flows.levelq) levelq_upload_construct_file_info() (in module punchpipe.flows.levelq) levelq_upload_construct_flow_info() (in module punchpipe.flows.levelq) levelq_upload_core_flow() (in module punchpipe.flows.levelq) levelq_upload_process_flow() (in module punchpipe.flows.levelq) levelq_upload_query_ready_files() (in module punchpipe.flows.levelq) levelq_upload_scheduler_flow() (in module punchpipe.flows.levelq) load() (punchpipe.control.cache_layer.loader_base_class.LoaderABC method) (punchpipe.control.cache_layer.nfi_l1.NFIL1Loader method) load_enabled_flows() (in module punchpipe.speedster) load_flow_data() (in module punchpipe.control.launcher) load_from_disk() (punchpipe.control.cache_layer.loader_base_class.LoaderABC method) (punchpipe.control.cache_layer.nfi_l1.NFIL1Loader method) (punchpipe.control.cache_layer.psf.PSFLoader method) (punchpipe.control.cache_layer.quartic_coefficients.QuarticLoader method) (punchpipe.control.cache_layer.stray_light.StrayLightLoader method) (punchpipe.control.cache_layer.vignetting_function.VignettingLoader method) (punchpipe.flows.level0.TLMLoader method) load_pipeline_configuration() (in module punchpipe.control.util) (in module punchpipe.speedster) load_quicklook_scaling() (in module punchpipe.control.util) LoaderABC (class in punchpipe.control.cache_layer.loader_base_class) loop (in module punchpipe.control.tests.test_cleaner)

M

main() (in module punchpipe.cli) (in module punchpipe.cluster) make_phases() (in module punchpipe.flows.dynamic_wfi_stray_light) make_y_axis_labels() (in module files) mapping (punchpipe.flows.level0.SpacecraftMapping attribute) match_data_with_file_db_entry() (in module punchpipe.control.tests) (in module punchpipe.control.util) memory_percentage (punchpipe.control.db.Health attribute) memory_usage (punchpipe.control.db.Health attribute) MissingCCSDSDataError module files home punchpipe punchpipe.cli punchpipe.cluster punchpipe.control punchpipe.control.cache_layer punchpipe.control.cache_layer.loader_base_class punchpipe.control.cache_layer.manager punchpipe.control.cache_layer.nfi_l1 punchpipe.control.cache_layer.psf punchpipe.control.cache_layer.quartic_coefficients punchpipe.control.cache_layer.stray_light punchpipe.control.cache_layer.vignetting_function punchpipe.control.cache_nanny punchpipe.control.cleaner punchpipe.control.db punchpipe.control.health punchpipe.control.launcher punchpipe.control.processor punchpipe.control.scheduler punchpipe.control.tests punchpipe.control.tests.conftest punchpipe.control.tests.test_cleaner punchpipe.control.tests.test_launcher punchpipe.control.tests.test_processor punchpipe.control.tests.test_scheduler punchpipe.control.tests.test_util punchpipe.control.util punchpipe.error punchpipe.flows punchpipe.flows.dynamic_wfi_stray_light punchpipe.flows.fcorona punchpipe.flows.level0 punchpipe.flows.level1 punchpipe.flows.level2 punchpipe.flows.level3 punchpipe.flows.levelh punchpipe.flows.levelq punchpipe.flows.simulate punchpipe.flows.starfield punchpipe.flows.stray_light punchpipe.flows.tests punchpipe.flows.tests.conftest punchpipe.flows.tests.test_level1 punchpipe.flows.tests.test_level2 punchpipe.flows.tests.test_levelQ punchpipe.flows.tests.test_replay punchpipe.flows.util punchpipe.flows.velocity punchpipe.flows.visualize punchpipe.monitor punchpipe.monitor.app punchpipe.speedster

movie_core_flow() (in module punchpipe.flows.visualize) movie_process_flow() (in module punchpipe.flows.visualize) movie_scheduler_flow() (in module punchpipe.flows.visualize)

N

NFI_PFW_POSITION_MAPPING (in module punchpipe.flows.level0) NFIL1Loader (class in punchpipe.control.cache_layer.nfi_l1) normal_core_flow() (in module punchpipe.control.tests.test_processor) normal_flow() (in module punchpipe.control.tests.test_processor)

num_attempts (punchpipe.control.db.SCI_XFI attribute) (punchpipe.control.db.TLMFiles attribute) num_images_failed (punchpipe.control.db.PacketHistory attribute) num_images_succeeded (punchpipe.control.db.PacketHistory attribute) num_pids (punchpipe.control.db.Health attribute)

O

observatory (punchpipe.control.db.File attribute) (punchpipe.control.tests.File attribute) open_and_split_packet_file() (in module punchpipe.flows.level0) operators (in module files) (in module home) organize_ceb_fits_keywords() (in module punchpipe.flows.level0) organize_compression_and_acquisition_settings() (in module punchpipe.flows.level0)

organize_gain_info() (in module punchpipe.flows.level0) organize_led_fits_keywords() (in module punchpipe.flows.level0) organize_lz_fits_keywords() (in module punchpipe.flows.level0) organize_pfw_fits_keywords() (in module punchpipe.flows.level0) organize_spacecraft_position_keywords() (in module punchpipe.flows.level0) outlier (punchpipe.control.db.File attribute) (punchpipe.control.tests.File attribute)

P

PACKET_CADENCE (in module punchpipe.flows.level0) packet_group (punchpipe.control.db.SCI_XFI attribute) packet_index (punchpipe.control.db.ENG_CEB attribute) (punchpipe.control.db.ENG_LED attribute) (punchpipe.control.db.ENG_LZ attribute) (punchpipe.control.db.ENG_PFW attribute) (punchpipe.control.db.ENG_XACT attribute) (punchpipe.control.db.SCI_XFI attribute) PacketHistory (class in punchpipe.control.db) PACKETNAME2SQL (in module punchpipe.control.db) PAGE_SIZE (in module files) (in module home) parent (punchpipe.control.db.FileRelationship attribute) parse_telemetry_file() (in module punchpipe.flows.level0) parser (in module punchpipe.speedster) path (punchpipe.control.cache_layer.nfi_l1.NFIL1Loader attribute) (punchpipe.control.cache_layer.psf.PSFLoader attribute) (punchpipe.control.cache_layer.quartic_coefficients.QuarticLoader attribute) (punchpipe.control.cache_layer.stray_light.StrayLightLoader attribute) (punchpipe.control.cache_layer.vignetting_function.VignettingLoader attribute) (punchpipe.control.db.TLMFiles attribute) (punchpipe.flows.level0.TLMLoader attribute) phase_in_window() (in module punchpipe.flows.dynamic_wfi_stray_light) pmr_mysql_config() (in module punchpipe.control.tests.conftest) (in module punchpipe.flows.tests.conftest) polarization (punchpipe.control.db.File attribute) (punchpipe.control.tests.File attribute) populated_tmpdir_config() (in module punchpipe.control.tests.test_cleaner) prefect_test_fixture() (in module punchpipe.control.tests.test_cleaner) (in module punchpipe.flows.tests.test_level1) priority (punchpipe.control.db.Flow attribute) processing_flow (punchpipe.control.db.File attribute) (punchpipe.control.tests.File attribute) PSF_MODEL_CORRESPONDING_TYPES (in module punchpipe.flows.level1) PSFLoader (class in punchpipe.control.cache_layer.psf) punchpipe module punchpipe.cli module punchpipe.cluster module punchpipe.control module punchpipe.control.cache_layer module punchpipe.control.cache_layer.loader_base_class module punchpipe.control.cache_layer.manager module punchpipe.control.cache_layer.nfi_l1 module punchpipe.control.cache_layer.psf module punchpipe.control.cache_layer.quartic_coefficients module punchpipe.control.cache_layer.stray_light module punchpipe.control.cache_layer.vignetting_function module punchpipe.control.cache_nanny module punchpipe.control.cleaner module punchpipe.control.db module punchpipe.control.health module punchpipe.control.launcher module punchpipe.control.processor module

punchpipe.control.scheduler module punchpipe.control.tests module punchpipe.control.tests.conftest module punchpipe.control.tests.test_cleaner module punchpipe.control.tests.test_launcher module punchpipe.control.tests.test_processor module punchpipe.control.tests.test_scheduler module punchpipe.control.tests.test_util module punchpipe.control.util module punchpipe.error module punchpipe.flows module punchpipe.flows.dynamic_wfi_stray_light module punchpipe.flows.fcorona module punchpipe.flows.level0 module punchpipe.flows.level1 module punchpipe.flows.level2 module punchpipe.flows.level3 module punchpipe.flows.levelh module punchpipe.flows.levelq module punchpipe.flows.simulate module punchpipe.flows.starfield module punchpipe.flows.stray_light module punchpipe.flows.tests module punchpipe.flows.tests.conftest module punchpipe.flows.tests.test_level1 module punchpipe.flows.tests.test_level2 module punchpipe.flows.tests.test_levelQ module punchpipe.flows.tests.test_replay module punchpipe.flows.util module punchpipe.flows.velocity module punchpipe.flows.visualize module punchpipe.monitor module punchpipe.monitor.app module punchpipe.speedster module PunchPipeError PunchPipeWarning

Q

QuarticLoader (class in punchpipe.control.cache_layer.quartic_coefficients)

R

read_tlm_defs() (in module punchpipe.flows.level0) REFRESH_RATE (in module files) (in module home) relationship_id (punchpipe.control.db.FileRelationship attribute)

reset_revivable_flows() (in module punchpipe.control.cleaner) run() (in module punchpipe.cli) run_control() (in module punchpipe.cli) run_data() (in module punchpipe.cli)

S

sample_punchdata() (in module punchpipe.control.tests) SC_TIME_EPOCH (in module punchpipe.flows.level0) schedule_columns (in module home) SCI_XFI (class in punchpipe.control.db) SCIENCE_CLEAR_LEVEL1_TYPES (in module punchpipe.flows.level2) SCIENCE_LEVEL0_TYPE_CODES (in module punchpipe.flows.level1) (in module punchpipe.flows.levelh) SCIENCE_LEVEL1_LATE_INPUT_TYPE_CODES (in module punchpipe.flows.level1) SCIENCE_LEVEL1_LATE_OUTPUT_TYPE_CODES (in module punchpipe.flows.level1) SCIENCE_LEVEL1_MIDDLE_INPUT_TYPE_CODES (in module punchpipe.flows.level1) SCIENCE_LEVEL1_MIDDLE_OUTPUT_TYPE_CODES (in module punchpipe.flows.level1) SCIENCE_LEVEL1_QUICK_INPUT_TYPE_CODES (in module punchpipe.flows.level1) SCIENCE_LEVEL1_QUICK_OUTPUT_TYPE_CODES (in module punchpipe.flows.level1) SCIENCE_POLARIZED_LEVEL1_TYPES (in module punchpipe.flows.level2) session_fn() (in module punchpipe.control.tests.test_cleaner) (in module punchpipe.control.tests.test_launcher) (in module punchpipe.control.tests.test_processor) (in module punchpipe.flows.tests.test_level1) (in module punchpipe.flows.tests.test_level2) (in module punchpipe.flows.tests.test_levelQ) session_fn_out_file_already_exists() (in module punchpipe.control.tests.test_processor) short_hash() (in module punchpipe.flows.level0) simpunch_core_flow() (in module punchpipe.flows.simulate) simpunch_process_flow() (in module punchpipe.flows.simulate) simpunch_scheduler_flow() (in module punchpipe.flows.simulate) software_version (punchpipe.control.db.File attribute) (punchpipe.control.tests.File attribute)

spacecraft_id (punchpipe.control.db.ENG_CEB attribute) (punchpipe.control.db.ENG_LED attribute) (punchpipe.control.db.ENG_LZ attribute) (punchpipe.control.db.ENG_PFW attribute) (punchpipe.control.db.ENG_XACT attribute) (punchpipe.control.db.SCI_XFI attribute) SpacecraftMapping (class in punchpipe.flows.level0) split_filter_part() (in module files) (in module home) src_repr() (punchpipe.control.cache_layer.loader_base_class.LoaderABC method) (punchpipe.control.cache_layer.nfi_l1.NFIL1Loader method) (punchpipe.control.cache_layer.psf.PSFLoader method) (punchpipe.control.cache_layer.quartic_coefficients.QuarticLoader method) (punchpipe.control.cache_layer.stray_light.StrayLightLoader method) (punchpipe.control.cache_layer.vignetting_function.VignettingLoader method) (punchpipe.flows.level0.TLMLoader method) starfield_background_query_ready_files() (in module punchpipe.flows.starfield) start_time (punchpipe.control.db.Flow attribute) state (punchpipe.control.db.File attribute) (punchpipe.control.db.Flow attribute) (punchpipe.control.tests.File attribute) STRAY_LIGHT_CORRESPONDING_TYPES (in module punchpipe.flows.level1) StrayLightLoader (class in punchpipe.control.cache_layer.stray_light) successful (punchpipe.control.db.TLMFiles attribute) summarize_files_missing_cal_files() (in module punchpipe.flows.util) summary() (punchpipe.control.db.File method) (punchpipe.control.tests.File method)

T

T (in module punchpipe.control.cache_layer.loader_base_class) TaiDatetimeConverter (class in punchpipe.flows.level0) test_clean_replay() (in module punchpipe.flows.tests.test_replay) test_clean_replay_connected_requests() (in module punchpipe.flows.tests.test_replay) test_clean_replay_empty() (in module punchpipe.flows.tests.test_replay) test_clean_replay_notime() (in module punchpipe.flows.tests.test_replay) test_clean_replay_one_request() (in module punchpipe.flows.tests.test_replay) test_count_running_flows() (in module punchpipe.control.tests.test_launcher) TEST_DIR (in module punchpipe.control.tests.test_cleaner) (in module punchpipe.control.tests.test_launcher) (in module punchpipe.flows.tests.test_level1) (in module punchpipe.flows.tests.test_level2) (in module punchpipe.flows.tests.test_levelQ) (in module punchpipe.flows.tests.test_replay) test_escalate_long_waiting_flows() (in module punchpipe.control.tests.test_launcher) test_filter_for_launchable_flows() (in module punchpipe.control.tests.test_launcher) test_filter_for_launchable_flows_with_empty_db() (in module punchpipe.control.tests.test_launcher) test_filter_for_launchable_flows_with_max_of_0() (in module punchpipe.control.tests.test_launcher) test_filter_for_launchable_flows_with_max_of_1() (in module punchpipe.control.tests.test_launcher) test_gather_queued_flows() (in module punchpipe.control.tests.test_launcher) test_generic_process_flow_fails_on_empty_db() (in module punchpipe.control.tests.test_processor) test_generic_process_flow_fails_on_out_file_existence() (in module punchpipe.control.tests.test_processor) test_group_l2_inputs_single_observatory() (in module punchpipe.flows.tests.test_level2) test_launch_ready_flows() (in module punchpipe.control.tests.test_launcher) test_level1_early_construct_file_info() (in module punchpipe.flows.tests.test_level1) test_level1_early_construct_file_info_clear() (in module punchpipe.flows.tests.test_level1) test_level1_early_construct_flow_info() (in module punchpipe.flows.tests.test_level1) test_level1_early_query_ready_files() (in module punchpipe.flows.tests.test_level1) test_level1_early_scheduler_flow() (in module punchpipe.flows.tests.test_level1) test_level1_late_construct_file_info() (in module punchpipe.flows.tests.test_level1) test_level1_late_construct_flow_info() (in module punchpipe.flows.tests.test_level1) test_level1_late_query_ready_files() (in module punchpipe.flows.tests.test_level1) test_level1_late_scheduler_flow() (in module punchpipe.flows.tests.test_level1) test_level1_middle_construct_file_info() (in module punchpipe.flows.tests.test_level1) test_level1_middle_construct_flow_info() (in module punchpipe.flows.tests.test_level1) test_level1_middle_query_ready_files() (in module punchpipe.flows.tests.test_level1) test_level1_middle_scheduler_flow() (in module punchpipe.flows.tests.test_level1) test_level1_process_flow() (in module punchpipe.flows.tests.test_level1) test_level2_clear_query_ready_files_unprocessed_L0() (in module punchpipe.flows.tests.test_level2) test_level2_construct_file_info() (in module punchpipe.flows.tests.test_level2) test_level2_construct_flow_info() (in module punchpipe.flows.tests.test_level2) test_level2_process_flow() (in module punchpipe.flows.tests.test_level2) test_level2_query_ready_files() (in module punchpipe.flows.tests.test_level2)

test_level2_query_ready_files_ignore_missing() (in module punchpipe.flows.tests.test_level2) test_level2_query_ready_files_ignore_missing_clear() (in module punchpipe.flows.tests.test_level2) test_level2_scheduler_flow() (in module punchpipe.flows.tests.test_level2) test_levelq_CQM_construct_file_info() (in module punchpipe.flows.tests.test_levelQ) test_levelq_CQM_construct_flow_info() (in module punchpipe.flows.tests.test_levelQ) test_levelq_CQM_query_ready_files() (in module punchpipe.flows.tests.test_levelQ) test_levelq_CQM_query_ready_files_ignore_missing() (in module punchpipe.flows.tests.test_levelQ) test_levelq_CQM_query_ready_files_unprocessed_L0() (in module punchpipe.flows.tests.test_levelQ) test_levelq_CTM_construct_file_info() (in module punchpipe.flows.tests.test_levelQ) test_levelq_CTM_construct_flow_info() (in module punchpipe.flows.tests.test_levelQ) test_levelq_CTM_query_ready_files() (in module punchpipe.flows.tests.test_levelQ) test_load_quicklook_scaling() (in module punchpipe.control.tests.test_util) test_load_quicklook_scaling_no_input() (in module punchpipe.control.tests.test_util) test_load_quicklook_scaling_no_product() (in module punchpipe.control.tests.test_util) test_match_data_with_file_db_entry() (in module punchpipe.control.tests) test_match_data_with_file_db_entry_fails_on_empty_list() (in module punchpipe.control.tests) test_reset_L1() (in module punchpipe.control.tests.test_cleaner) test_reset_L2() (in module punchpipe.control.tests.test_cleaner) test_reset_LQ() (in module punchpipe.control.tests.test_cleaner) test_simple_generic_process_flow_normal_return() (in module punchpipe.control.tests.test_processor) test_simple_generic_process_flow_unreported() (in module punchpipe.control.tests.test_processor) TESTDATA_DIR (in module punchpipe.control.tests.test_processor) (in module punchpipe.control.tests.test_util) THIS_DIR (in module punchpipe.cli) timestamp (punchpipe.control.db.ENG_CEB attribute) (punchpipe.control.db.ENG_LED attribute) (punchpipe.control.db.ENG_LZ attribute) (punchpipe.control.db.ENG_PFW attribute) (punchpipe.control.db.ENG_XACT attribute) (punchpipe.control.db.SCI_XFI attribute) tlm_id (punchpipe.control.db.ENG_CEB attribute) (punchpipe.control.db.ENG_LED attribute) (punchpipe.control.db.ENG_LZ attribute) (punchpipe.control.db.ENG_PFW attribute) (punchpipe.control.db.ENG_XACT attribute) (punchpipe.control.db.SCI_XFI attribute) (punchpipe.control.db.TLMFiles attribute) TLMFiles (class in punchpipe.control.db) TLMLoader (class in punchpipe.flows.level0) to_bytes() (punchpipe.control.cache_layer.loader_base_class.LoaderABC method) toggle_auto_refresh() (in module files) try_caching() (punchpipe.control.cache_layer.loader_base_class.LoaderABC method) try_read_from_key() (in module punchpipe.control.cache_layer.manager) try_write_to_key() (in module punchpipe.control.cache_layer.manager)

U

unpack_acquisition_settings() (in module punchpipe.flows.level0) unpack_compression_settings() (in module punchpipe.flows.level0) unpack_n_bit_values() (in module punchpipe.flows.level0) update_cards() (in module home) update_file_cards() (in module home) update_file_graph() (in module files)

update_file_state() (in module punchpipe.control.util) update_flow_stats() (in module home) update_flows() (in module home) update_machine_stats() (in module home) update_table() (in module files) update_visible_columns() (in module files) USABLE_COLUMNS (in module files)

V

VARIABLE_PACKETS (in module punchpipe.flows.level0) VIGNETTING_CORRESPONDING_TYPES (in module punchpipe.flows.level1)

VignettingLoader (class in punchpipe.control.cache_layer.vignetting_function) visualize_flow_info() (in module punchpipe.flows.visualize) visualize_query_ready_files() (in module punchpipe.flows.visualize)

W

WFI_PFW_POSITION_MAPPING (in module punchpipe.flows.level0) worker_init() (in module punchpipe.speedster) worker_run_flow() (in module punchpipe.speedster) wrap_if_appropriate() (in module punchpipe.control.cache_layer.nfi_l1) (in module punchpipe.control.cache_layer.psf) (in module punchpipe.control.cache_layer.quartic_coefficients) (in module punchpipe.control.cache_layer.stray_light) (in module punchpipe.control.cache_layer.vignetting_function) (in module punchpipe.flows.level0)

write_file() (in module punchpipe.control.util) write_manifest() (in module punchpipe.flows.levelq)