Skip to content

Initial Status Communications - #84

Merged
mxkpp merged 38 commits into
developmentfrom
maxkipp-status-comms
Jun 3, 2026
Merged

Initial Status Communications#84
mxkpp merged 38 commits into
developmentfrom
maxkipp-status-comms

Conversation

@mxkpp

@mxkpp mxkpp commented May 29, 2026

Copy link
Copy Markdown
Contributor

Adds collection of status communications via parsing of logs (and optional payloads within the logs) of nwm-msw-mgr, nwm-fcst-mgr, and ngen (and its MPI ranks and submodules) during ngen execution.

Also reports basic status of nwm-msw-mgr and nwm-fcst-mgr directly (without being dependent on reading their logs to discover their payloads).

Adds EWTS to nwm-rte.

Adds transmissions from nwm-rte, e.g. to support communication with ecFlow and other aspects of the operational environment.

Consolidates some log paths (for docker build, docker run, and the nwm-rte and ngen runtime logs).

This should be reviewed in conjunction with these PRs of other repositories:

NGWPC/nwm-msw-mgr#84
NGWPC/nwm-fcst-mgr#23
NGWPC/ngen-forcing#170

mxkpp added 26 commits May 29, 2026 20:06
… report them for run_default.py, run_forecast.py, and run_calibration.py.
… BaseModel to dataclass. Async ngen: add optional postprocess call, expose destructor (close).
…s for default, forecast, and calibration in VS Code debugger
…on and log parsing, remove support for arg quit_forecast_after_forcing_running.
… Add ewts to nwm-rte and use log calls instead of print.
@mxkpp
mxkpp force-pushed the maxkipp-status-comms branch from 2d03d61 to e3f402c Compare May 30, 2026 00:08

@zhengtaocui zhengtaocui left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

My test run was successful and I see the captured logs by RTE. The location of the dumped log is currently in the current working directory. It would be better to move it to the temporary working directory passed by EcFlow or make it configurable.
I also have another comment about the async execution ngen. I'm not sure if it is a background process. Just want you know that background is not allowed in production.

Comment thread bin_mounted/ngen_rte/execution/ngen_async.py

@zhengtaocui zhengtaocui left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It looks good to me.

@mxkpp

mxkpp commented Jun 2, 2026

Copy link
Copy Markdown
Contributor Author

Regarding the location of the logs, they currently go to ./nwm-rte/logs/rte/. I think a separate PR can include additional flexibility around that, and potentially change the default log dir to be the realization's work dir, if that is desired.

@mxkpp
mxkpp merged commit 603c89d into development Jun 3, 2026
7 checks passed
@mxkpp
mxkpp deleted the maxkipp-status-comms branch June 3, 2026 03:16
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants