punchpipe.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#

punchpipe.cli.THIS_DIR#

punchpipe.cli.main()[source]#: Run the PUNCH automated pipeline

punchpipe.cli.find_flow(target_flow, subpackage='flows') → prefect.Flow[source]#

punchpipe.cli.construct_flows_to_serve(configuration_path, include_data=True, include_control=True)[source]#

punchpipe.cli.run_data(configuration_path)[source]#

punchpipe.cli.run_control(configuration_path)[source]#

punchpipe.cli.run(configuration_path, launch_prefect=False, launch_dask_cluster=False)[source]#

punchpipe.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[source]#: Clean replay requests