From 57400b77ee59d9ea8fe237ba3eb083cb4aee5a28 Mon Sep 17 00:00:00 2001 From: Marcus Hughes Date: Tue, 3 Dec 2024 08:54:31 -0700 Subject: [PATCH] fix flow names --- punchpipe/cli.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/punchpipe/cli.py b/punchpipe/cli.py index e7da21e..0e2638e 100644 --- a/punchpipe/cli.py +++ b/punchpipe/cli.py @@ -105,7 +105,7 @@ def serve_flows(configuration_path): level3_PIM_scheduler_deployment = level3_PIM_scheduler_flow.to_deployment(name="level3-PIM-scheduler-deployment", description="Schedule a Level 3 flow to make PIM.", tags=["L3", "scheduler"], - cron=config['levels']['L3_PIM'].get("schedule", "* * * * *"), + cron=config['levels']['level3_PIM_process_flow'].get("schedule", "* * * * *"), parameters={ "pipeline_config_path": configuration_path} @@ -119,7 +119,7 @@ def serve_flows(configuration_path): f_corona_scheduler_dep = f_corona_scheduler.to_deployment(name="construct_f_corona_background-scheduler-deployment", description="Schedule an F corona background.", - cron=config['levels']['f_corona'].get("schedule", "* * * * *"), + cron=config['levels']['construct_f_corona_background_process_flow'].get("schedule", "* * * * *"), tags=["L3", "scheduler"], parameters={ "pipeline_config_path": configuration_path} @@ -134,7 +134,7 @@ def serve_flows(configuration_path): starfield_scheduler_dep = starfield_scheduler_flow.to_deployment(name="construct_starfield-scheduler-deployment", description="Schedule a starfield background.", - cron=config['levels']['starfield'].get("schedule", "* * * * *"), + cron=config['levels']['construct_starfield_background_process_flow'].get("schedule", "* * * * *"), tags=["L3", "scheduler"], parameters={"pipeline_config_path": configuration_path} @@ -148,7 +148,7 @@ def serve_flows(configuration_path): level3_PTM_scheduler_deployment = level3_PTM_scheduler_flow.to_deployment(name="level3-PTM-scheduler-deployment", description="Schedule a Level 3 flow to make PTM.", - cron=config['levels']['L3_PTM'].get("schedule", "* * * * *"), + cron=config['levels']['level3_PTM_process_flow'].get("schedule", "* * * * *"), tags=["L3", "scheduler"], parameters={ "pipeline_config_path": configuration_path}