Skip to content

Commit 2f3f2c6

Browse files
committed
Make workflow case insensitive
1 parent 2c24026 commit 2f3f2c6

3 files changed

Lines changed: 9 additions & 3 deletions

File tree

src/rushti/commands.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1667,7 +1667,8 @@ def _stats_visualize(args) -> None:
16671667

16681668
# Prefer DB-based DAG (no taskfile on disk needed); fall back to taskfile if unavailable.
16691669
runs = data["runs"]
1670-
workflow_runs = [r for r in runs if (r.get("workflow") or "") == args.workflow]
1670+
workflow_lower = args.workflow.lower()
1671+
workflow_runs = [r for r in runs if (r.get("workflow") or "").lower() == workflow_lower]
16711672
latest_run = workflow_runs[0] if workflow_runs else None
16721673

16731674
dag_generated_from_db = False

src/rushti/dashboard.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -212,6 +212,10 @@ def _prepare_dashboard_data(
212212
tasks_by_run[run_id] = []
213213
tasks_by_run[run_id].append(tr)
214214

215+
# Normalize workflow names to lowercase for case-insensitive aggregation
216+
if selected_workflow is not None:
217+
selected_workflow = selected_workflow.lower()
218+
215219
# Build enriched run data
216220
enriched_runs = []
217221
for run in runs:
@@ -222,6 +226,7 @@ def _prepare_dashboard_data(
222226
enriched_runs.append(
223227
{
224228
**run,
229+
"workflow": (run.get("workflow") or "").lower(),
225230
"stats": run_stats,
226231
"concurrency": concurrency,
227232
"task_count_actual": len(run_tasks),

src/rushti/db_admin.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -921,7 +921,7 @@ def get_visualization_data(
921921
run[field] = bool(run[field])
922922
runs.append(run)
923923
run_ids.append(run["run_id"])
924-
if run.get("workflow") == workflow:
924+
if (run.get("workflow") or "").lower() == workflow.lower():
925925
has_selected_workflow = True
926926

927927
if include_all_workflows and workflow and not has_selected_workflow:
@@ -976,7 +976,7 @@ def get_visualization_data(
976976

977977
run_info = backend.get_run_info(run_id) or {}
978978
run_workflow = run_info.get("workflow") or summary.get("workflow") or workflow
979-
if run_workflow == workflow:
979+
if run_workflow.lower() == workflow.lower():
980980
has_selected_workflow = True
981981
run = {
982982
"run_id": run_id,

0 commit comments

Comments
 (0)