Skip to content

Merge OWP Master Changes into Development (NGWPC-9802) #8

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
idtodd merged 1 commit into from
Feb 18, 2026
Merged

Merge OWP Master Changes into Development (NGWPC-9802) #8

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 7 additions & 3 deletions lstm/bmi_lstm.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,10 @@
import pandas as pd
import torch
import yaml
try:
from yaml import CSafeLoader as SafeLoader
except ImportError:
from yaml import SafeLoader

from . import nextgen_cuda_lstm
from .base import BmiBase
Expand Down Expand Up @@ -147,7 +151,7 @@ def __init__(self, cfg: dict[str, typing.Any], output_scaling_factor_cms: float)
# load training feature scales
scaler_file = cfg["run_dir"] / "train_data/train_data_scaler.yml"
with scaler_file.open("r") as fp:
train_data_scaler = yaml.safe_load(fp)
train_data_scaler = yaml.load(fp, Loader=SafeLoader)
self.scalars = load_training_scalars(cfg, train_data_scaler)

# initialize torch lstm object
Expand Down Expand Up @@ -428,7 +432,7 @@ def initialize(self, config_file: str) -> None:

# read and setup main configuration file
with open(config_file, "r") as fp:
self.cfg_bmi = yaml.safe_load(fp)
self.cfg_bmi = yaml.load(fp, Loader=SafeLoader)
coerce_config(self.cfg_bmi)

# ----------- The output is area normalized, this is needed to un-normalize it
Expand All @@ -440,7 +444,7 @@ def initialize(self, config_file: str) -> None:
# initialize ensemble members
self.ensemble_members = []
for member_cfg_file in self.cfg_bmi["train_cfg_file"]:
cfg = yaml.safe_load(member_cfg_file.read_text())
cfg = yaml.load(member_cfg_file.read_text(), Loader=SafeLoader)
coerce_config(cfg)
member = EnsembleMember(cfg, output_factor_cms)
self.ensemble_members.append(member)
Expand Down