punchpipe.flows.visualize

Functions

visualize_query_ready_files(session, pipeline_config, ...)
visualize_flow_info(input_files, product_code, ...[, ...])
movie_scheduler_flow([pipeline_config_path, session, ...])
generate_flow_run_name()
movie_core_flow(→ None)
movie_process_flow(flow_id[, pipeline_config_path, ...])

Module Contents

punchpipe.flows.visualize.visualize_query_ready_files(session, pipeline_config: dict, reference_time: datetime.datetime, lookback_hours: float = 24)

punchpipe.flows.visualize.visualize_flow_info(input_files: list[punchpipe.control.db.File], product_code: str, pipeline_config: dict, reference_time: datetime.datetime, session=None, framerate: int = 5, resolution: int = 1024)

punchpipe.flows.visualize.movie_scheduler_flow(pipeline_config_path=None, session=None, reference_time: datetime.datetime | None = None, look_back_hours: float = 24, framerate: int = 5, resolution: int = 1024)

punchpipe.flows.visualize.generate_flow_run_name()

punchpipe.flows.visualize.movie_core_flow(file_list: list, product_code: str, output_movie_dir: str, framerate: int = 5, resolution: int = 1024, ffmpeg_cmd: str = 'ffmpeg') → None

punchpipe.flows.visualize.movie_process_flow(flow_id: int, pipeline_config_path=None, session=None)