diff --git a/.gitignore b/.gitignore index d2388cd..b155c0d 100644 --- a/.gitignore +++ b/.gitignore @@ -2,3 +2,6 @@ scripts/credentials.py /docs/build/ /venv/ /venv-docs/ +build/ +punchpipe.egg-info +.idea \ No newline at end of file diff --git a/punchpipe/controlsegment/launcher.py b/punchpipe/controlsegment/launcher.py index bad791b..343899a 100644 --- a/punchpipe/controlsegment/launcher.py +++ b/punchpipe/controlsegment/launcher.py @@ -49,7 +49,7 @@ def filter_for_launchable_flows(planned_flows, running_flow_count, max_flows_run @task -async def launch_ready_flows(session: Session, flow_ids: List[int]): +async def launch_ready_flows(session: Session, flow_ids: List[int]) -> List: """Given a list of ready-to-launch flow_ids, this task creates flow runs in Prefect for them. These flow runs are automatically marked as scheduled in Prefect and will be picked up by a work queue and agent as soon as possible. @@ -96,10 +96,8 @@ def launcher_flow(pipeline_configuration_path="config.yaml"): """ logger = get_run_logger() - # load pipeline configuration pipeline_config = load_pipeline_configuration(pipeline_configuration_path) - # Get database credentials and establish a connection logger.info("Establishing database connection") session = get_database_session()