punchpipe.speedster# Attributes# parser Functions# load_pipeline_configuration(→ dict) load_enabled_flows(pipeline_config) gather_planned_flows(session, enabled_flows[, max_n]) worker_init(config_path) worker_run_flow(inputs) Module Contents# punchpipe.speedster.load_pipeline_configuration(path: str = None) → dict[source]# punchpipe.speedster.load_enabled_flows(pipeline_config)[source]# punchpipe.speedster.gather_planned_flows(session, enabled_flows, max_n=None)[source]# punchpipe.speedster.worker_init(config_path)[source]# punchpipe.speedster.worker_run_flow(inputs)[source]# punchpipe.speedster.parser#
