Spaces:
Running
Running
Deploy Space: update src
Browse files- src/utils.py +8 -2
src/utils.py
CHANGED
|
@@ -672,6 +672,12 @@ def make_domain_pie_chart(root_dir: str = "results") -> object | None:
|
|
| 672 |
for _, row in props.iterrows():
|
| 673 |
domain_map[str(row["dataset"]).lower()] = display_domain(str(row["domain"]))
|
| 674 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 675 |
today_start = _today_start_utc8()
|
| 676 |
utc8 = today_start.tzinfo
|
| 677 |
|
|
@@ -693,7 +699,7 @@ def make_domain_pie_chart(root_dir: str = "results") -> object | None:
|
|
| 693 |
if eval_dt.astimezone(utc8) >= today_start:
|
| 694 |
ds_base = entry.get("dataset", "")
|
| 695 |
pred_len = entry.get("prediction_length", 0)
|
| 696 |
-
domain =
|
| 697 |
timestamp_counts[domain] = timestamp_counts.get(domain, 0) + pred_len
|
| 698 |
domain_datasets.setdefault(domain, set()).add(dataset_short_name(ds_base))
|
| 699 |
except Exception:
|
|
@@ -727,7 +733,7 @@ def make_domain_pie_chart(root_dir: str = "results") -> object | None:
|
|
| 727 |
continue
|
| 728 |
seen_datasets.add(ds_base)
|
| 729 |
|
| 730 |
-
domain =
|
| 731 |
n_ts = len(snap.get("context", [])) + len(snap.get("actuals", []))
|
| 732 |
timestamp_counts[domain] = timestamp_counts.get(domain, 0) + n_ts
|
| 733 |
domain_datasets.setdefault(domain, set()).add(dataset_short_name(ds_base))
|
|
|
|
| 672 |
for _, row in props.iterrows():
|
| 673 |
domain_map[str(row["dataset"]).lower()] = display_domain(str(row["domain"]))
|
| 674 |
|
| 675 |
+
def get_domain(ds_name: str) -> str:
|
| 676 |
+
ds_lower = ds_name.lower()
|
| 677 |
+
if ds_lower not in domain_map:
|
| 678 |
+
domain_map[ds_lower] = display_domain(lookup_dataset_domain(ds_name, root_dir))
|
| 679 |
+
return domain_map[ds_lower]
|
| 680 |
+
|
| 681 |
today_start = _today_start_utc8()
|
| 682 |
utc8 = today_start.tzinfo
|
| 683 |
|
|
|
|
| 699 |
if eval_dt.astimezone(utc8) >= today_start:
|
| 700 |
ds_base = entry.get("dataset", "")
|
| 701 |
pred_len = entry.get("prediction_length", 0)
|
| 702 |
+
domain = get_domain(ds_base)
|
| 703 |
timestamp_counts[domain] = timestamp_counts.get(domain, 0) + pred_len
|
| 704 |
domain_datasets.setdefault(domain, set()).add(dataset_short_name(ds_base))
|
| 705 |
except Exception:
|
|
|
|
| 733 |
continue
|
| 734 |
seen_datasets.add(ds_base)
|
| 735 |
|
| 736 |
+
domain = get_domain(ds_base)
|
| 737 |
n_ts = len(snap.get("context", [])) + len(snap.get("actuals", []))
|
| 738 |
timestamp_counts[domain] = timestamp_counts.get(domain, 0) + n_ts
|
| 739 |
domain_datasets.setdefault(domain, set()).add(dataset_short_name(ds_base))
|