punchbowl.auto.flows.level3

Functions

get_valid_starfields(session, f, timedelta_window[, ...])
get_valid_fcorona_models(session, f, before_timedelta, ...)
get_fcorona_pairs(session, files[, model_type])
level3_PTM_query_ready_files(session, pipeline_config)
level3_PTM_construct_flow_info(level2_files, ...[, ...])
level3_PTM_construct_file_info(...)
level3_PTM_scheduler_flow([pipeline_config_path, ...])
level3_PTM_call_data_processor(→ dict)
level3_PTM_process_flow(flow_id[, ...])
level3_PIM_query_ready_files(session, pipeline_config)
level3_PIM_construct_flow_info(level2_files, ...[, ...])
level3_PIM_construct_file_info(...)
level3_PIM_scheduler_flow([pipeline_config_path, ...])
level3_PIM_call_data_processor(→ dict)
level3_PIM_process_flow(flow_id[, ...])
level3_CIM_PIM_query_ready_files(session, pipeline_config)
level3_CIM_construct_flow_info(level2_files, ...[, ...])
level3_CIM_construct_file_info(...)
level3_CIM_scheduler_flow([pipeline_config_path, ...])
level3_CIM_call_data_processor(→ dict)
level3_CIM_process_flow(flow_id[, ...])
level3_CTM_query_ready_files(session, pipeline_config)
level3_CTM_construct_flow_info(level2_files, ...[, ...])
level3_CTM_construct_file_info(...)
level3_CTM_scheduler_flow([pipeline_config_path, ...])
level3_CTM_call_data_processor(→ dict)
level3_CTM_process_flow(flow_id[, ...])
level3_CAM_query_ready_files(session, pipeline_config)
level3_PAM_query_ready_files(session, pipeline_config)
_level3_CAMPAM_query_ready_files(session, polarized, ...)
level3_CAMPAM_construct_flow_info(level3_files, ...[, ...])
level3_CAMPAM_construct_file_info(...)
level3_CAM_scheduler_flow([pipeline_config_path, session])
level3_CAM_process_flow(flow_id[, ...])
level3_PAM_scheduler_flow([pipeline_config_path, session])
level3_PAM_process_flow(flow_id[, ...])

Module Contents

punchbowl.auto.flows.level3.get_valid_starfields(session, f: punchbowl.auto.control.db.File, timedelta_window: datetime.timedelta, file_type: str = 'PS')

punchbowl.auto.flows.level3.get_valid_fcorona_models(session, f: punchbowl.auto.control.db.File, before_timedelta: datetime.timedelta, after_timedelta: datetime.timedelta, file_type='PF')

punchbowl.auto.flows.level3.get_fcorona_pairs(session, files: list[punchbowl.auto.control.db.File], model_type='PF')

punchbowl.auto.flows.level3.level3_PTM_query_ready_files(session, pipeline_config: dict, reference_time=None, max_n=9e+99)

punchbowl.auto.flows.level3.level3_PTM_construct_flow_info(level2_files: list[punchbowl.auto.control.db.File], level3_file: punchbowl.auto.control.db.File, pipeline_config: dict, session=None, reference_time=None)

punchbowl.auto.flows.level3.level3_PTM_construct_file_info(input_files: list[punchbowl.auto.control.db.File], pipeline_config: dict, reference_time=None) → list[punchbowl.auto.control.db.File]

punchbowl.auto.flows.level3.level3_PTM_scheduler_flow(pipeline_config_path=None, session=None, reference_time=None)

punchbowl.auto.flows.level3.level3_PTM_call_data_processor(call_data: dict, pipeline_config, session=None) → dict

punchbowl.auto.flows.level3.level3_PTM_process_flow(flow_id: int | list[int], pipeline_config_path=None, session=None)

punchbowl.auto.flows.level3.level3_PIM_query_ready_files(session, pipeline_config: dict, reference_time=None, max_n=9e+99)

punchbowl.auto.flows.level3.level3_PIM_construct_flow_info(level2_files: list[punchbowl.auto.control.db.File], level3_file: punchbowl.auto.control.db.File, pipeline_config: dict, session=None, reference_time=None)

punchbowl.auto.flows.level3.level3_PIM_construct_file_info(level2_files: list[punchbowl.auto.control.db.File], pipeline_config: dict, reference_time=None) → list[punchbowl.auto.control.db.File]

punchbowl.auto.flows.level3.level3_PIM_scheduler_flow(pipeline_config_path: str | None = None, session=None, reference_time: datetime.datetime | None = None)

punchbowl.auto.flows.level3.level3_PIM_call_data_processor(call_data: dict, pipeline_config, session=None) → dict

punchbowl.auto.flows.level3.level3_PIM_process_flow(flow_id: int | list[int], pipeline_config_path=None, session=None)

punchbowl.auto.flows.level3.level3_CIM_PIM_query_ready_files(session, pipeline_config: dict, reference_time=None, max_n=9e+99, polarized: bool = False)

punchbowl.auto.flows.level3.level3_CIM_construct_flow_info(level2_files: list[punchbowl.auto.control.db.File], level3_file: punchbowl.auto.control.db.File, pipeline_config: dict, session=None, reference_time=None)

punchbowl.auto.flows.level3.level3_CIM_construct_file_info(level2_files: list[punchbowl.auto.control.db.File], pipeline_config: dict, reference_time=None) → list[punchbowl.auto.control.db.File]

punchbowl.auto.flows.level3.level3_CIM_scheduler_flow(pipeline_config_path: str | None = None, session=None, reference_time: datetime.datetime | None = None)

punchbowl.auto.flows.level3.level3_CIM_call_data_processor(call_data: dict, pipeline_config, session=None) → dict

punchbowl.auto.flows.level3.level3_CIM_process_flow(flow_id: int | list[int], pipeline_config_path=None, session=None)

punchbowl.auto.flows.level3.level3_CTM_query_ready_files(session, pipeline_config: dict, reference_time=None, max_n=9e+99)

punchbowl.auto.flows.level3.level3_CTM_construct_flow_info(level2_files: list[punchbowl.auto.control.db.File], level3_file: punchbowl.auto.control.db.File, pipeline_config: dict, session=None, reference_time=None)

punchbowl.auto.flows.level3.level3_CTM_construct_file_info(input_files: list[punchbowl.auto.control.db.File], pipeline_config: dict, reference_time=None) → list[punchbowl.auto.control.db.File]

punchbowl.auto.flows.level3.level3_CTM_scheduler_flow(pipeline_config_path=None, session=None, reference_time=None)

punchbowl.auto.flows.level3.level3_CTM_call_data_processor(call_data: dict, pipeline_config, session=None) → dict

punchbowl.auto.flows.level3.level3_CTM_process_flow(flow_id: int | list[int], pipeline_config_path=None, session=None)

punchbowl.auto.flows.level3.level3_CAM_query_ready_files(session, pipeline_config: dict, reference_time=None, max_n=100)

punchbowl.auto.flows.level3.level3_PAM_query_ready_files(session, pipeline_config: dict, reference_time=None, max_n=100)

punchbowl.auto.flows.level3._level3_CAMPAM_query_ready_files(session, polarized: bool, pipeline_config: dict, reference_time=None, max_n=100)

punchbowl.auto.flows.level3.level3_CAMPAM_construct_flow_info(level3_files: list[punchbowl.auto.control.db.File], level3_file_out: punchbowl.auto.control.db.File, pipeline_config: dict, session=None, reference_time=None)

punchbowl.auto.flows.level3.level3_CAMPAM_construct_file_info(level3_files: list[punchbowl.auto.control.db.File], pipeline_config: dict, reference_time=None) → list[punchbowl.auto.control.db.File]

punchbowl.auto.flows.level3.level3_CAM_scheduler_flow(pipeline_config_path=None, session=None)

punchbowl.auto.flows.level3.level3_CAM_process_flow(flow_id: int | list[int], pipeline_config_path=None, session=None)

punchbowl.auto.flows.level3.level3_PAM_scheduler_flow(pipeline_config_path=None, session=None)

punchbowl.auto.flows.level3.level3_PAM_process_flow(flow_id: int | list[int], pipeline_config_path=None, session=None)