punchbowl.auto.cli#

Attributes#

Functions#

main()

Run the PUNCH automated pipeline

find_flow(→ prefect.Flow)

construct_flows_to_serve(configuration_path[, ...])

run_data(configuration_path)

run_control(configuration_path)

run(configuration_path[, launch_prefect, ...])

clean_replay(→ None | pandas.DataFrame)

Clean replay requests

Module Contents#

punchbowl.auto.cli.THIS_DIR#
punchbowl.auto.cli.main()#

Run the PUNCH automated pipeline

punchbowl.auto.cli.find_flow(target_flow, subpackage='flows') prefect.Flow#
punchbowl.auto.cli.construct_flows_to_serve(configuration_path, include_data=True, include_control=True)#
punchbowl.auto.cli.run_data(configuration_path)#
punchbowl.auto.cli.run_control(configuration_path)#
punchbowl.auto.cli.run(configuration_path, launch_prefect=False, launch_dask_cluster=False)#
punchbowl.auto.cli.clean_replay(input_file: str, configuration_path, write: bool = True, window_in_days: int | None = None, reference_date: None | datetime.datetime = None) None | pandas.DataFrame#

Clean replay requests