punchbowl.auto.flows.velocity

Functions

level3_vam_query_ready_files(session, pipeline_config, ...)
level3_vam_construct_flow_info(level3_ctm_files, ...)
level3_vam_construct_file_info(level3_files, ...)
level3_vam_scheduler_flow([pipeline_config_path, ...])
level3_vam_call_data_processor(→ dict)
level3_vam_process_flow(flow_id[, ...])
level3_van_query_ready_files(session, pipeline_config, ...)
level3_van_construct_flow_info(level3_cnn_files, ...)
level3_van_construct_file_info(level3_files, ...)
level3_van_scheduler_flow([pipeline_config_path, ...])
level3_van_call_data_processor(→ dict)
level3_van_process_flow(flow_id[, ...])

Module Contents

punchbowl.auto.flows.velocity.level3_vam_query_ready_files(session, pipeline_config: dict, reference_time: datetime.datetime)

punchbowl.auto.flows.velocity.level3_vam_construct_flow_info(level3_ctm_files: list[punchbowl.auto.control.db.File], level3_velocity_file: punchbowl.auto.control.db.File, pipeline_config: dict, reference_time: datetime.datetime, session=None)

punchbowl.auto.flows.velocity.level3_vam_construct_file_info(level3_files: list[punchbowl.auto.control.db.File], pipeline_config: dict, reference_time: datetime.datetime)

punchbowl.auto.flows.velocity.level3_vam_scheduler_flow(pipeline_config_path=None, session=None, reference_time: datetime.datetime | None = None)

punchbowl.auto.flows.velocity.level3_vam_call_data_processor(call_data: dict, pipeline_config, session=None) → dict

punchbowl.auto.flows.velocity.level3_vam_process_flow(flow_id: int, pipeline_config_path=None, session=None)

punchbowl.auto.flows.velocity.level3_van_query_ready_files(session, pipeline_config: dict, reference_time: datetime.datetime)

punchbowl.auto.flows.velocity.level3_van_construct_flow_info(level3_cnn_files: list[punchbowl.auto.control.db.File], level3_velocity_file: punchbowl.auto.control.db.File, pipeline_config: dict, reference_time: datetime.datetime, session=None)

punchbowl.auto.flows.velocity.level3_van_construct_file_info(level3_files: list[punchbowl.auto.control.db.File], pipeline_config: dict, reference_time: datetime.datetime)

punchbowl.auto.flows.velocity.level3_van_scheduler_flow(pipeline_config_path=None, session=None, reference_time: datetime.datetime | None = None)

punchbowl.auto.flows.velocity.level3_van_call_data_processor(call_data: dict, pipeline_config, session=None) → dict

punchbowl.auto.flows.velocity.level3_van_process_flow(flow_id: int, pipeline_config_path=None, session=None)