renaming functions

mlexchange · Mar 8, 2024 · 8b71057 · 8b71057
1 parent fa7c344
commit 8b71057
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/utils/prefect.py b/utils/prefect.py
@@ -79,7 +79,7 @@ async def _flow_run_query(
         return flow_runs
 
 
-def get_flow_runs_statuses(flow_run_name=None, tags=None):
+def get_flow_runs_by_name(flow_run_name=None, tags=None):
     flow_runs_by_name = []
     flow_runs = asyncio.run(_flow_run_query(tags, flow_run_name=flow_run_name))
     for flow_run in flow_runs:
@@ -93,7 +93,7 @@ def get_flow_runs_statuses(flow_run_name=None, tags=None):
     return flow_runs_by_name
 
 
-def get_children_flows_run_ids(parent_flow_run_id, sort="START_TIME_ASC"):
+def get_children_flow_run_ids(parent_flow_run_id, sort="START_TIME_ASC"):
     children_flow_runs = asyncio.run(
         _flow_run_query(parent_flow_run_id=parent_flow_run_id, sort=sort)
     )