Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
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
84 changes: 0 additions & 84 deletions .github/workflows/test_teehr_integration.yaml

This file was deleted.

2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
# DataStreamCLI
DataStreamCLI is a stand alone tool that automates the complete workflow from preprocessing input data for [NextGen](https://github.com/NOAA-OWP/ngen) to execution of the NextGen simulation through [NextGen In a Box](https://github.com/CIROH-UA/NGIAB-CloudInfra) (NGIAB).

DataStreamCLI serves as the workflow tooling for the [NextGen Research DataStream](https://github.com/CIROH-UA/ngen-datastream). This software allows users to run NextGen in an efficient, _relatively_ painless, and reproducible fashion while providing flexibility and integrations like forcingprocessor hfsubset, NextGen In A Box, and TEEHR.
DataStreamCLI serves as the workflow tooling for the [NextGen Research DataStream](https://github.com/CIROH-UA/ngen-datastream). This software allows users to run NextGen in an efficient, _relatively_ painless, and reproducible fashion while providing flexibility and integrations like forcingprocessor hfsubset and NextGen In A Box.

![datastream](docs/images/datastreamcli.jpg)

Expand Down
1 change: 0 additions & 1 deletion STATUS.md
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@
* ![](https://github.com/CIROH-UA/datastreamcli/actions/workflows/test_hfsubset_v2_1.yaml/badge.svg)
* ![](https://github.com/CIROH-UA/datastreamcli/actions/workflows/test_hfsubset_v2_2.yaml/badge.svg) -->
* ![](https://github.com/CIROH-UA/datastreamcli/actions/workflows/test_datastream_ngiab.yaml/badge.svg)
* ![](https://github.com/CIROH-UA/datastreamcli/actions/workflows/test_teehr_integration.yaml/badge.svg)

# DataStreamCLI Python
* ![](https://github.com/CIROH-UA/datastreamcli/actions/workflows/test_datastream_python_validation.yaml/badge.svg)
Expand Down
2 changes: 0 additions & 2 deletions docs/DATASTREAM_OPTIONS.md
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,6 @@ or run with cli args
-o, --S3_PREFIX <File prefix within s3 bucket>
-n, --NPROCS <Process limit>
-y, --DRYRUN <True to skip calculations>
-E, --EVAL <True to run TEEHR evaluation service>
-L, --LSTM_ENS_MEMBERS <LSTM ensemble members. 012345>

```
Expand All @@ -50,7 +49,6 @@ or run with cli args
| DRYRUN | `-y` | Set to "True" to skip all compute steps. |
| NPROCS | `-n` | Maximum number of processes to use in any step of `datastreamcli`. Defaults to `nprocs - 2` | |
| CONF_FILE | `-c` | Store CLI args as env variables in a file. | |
| EVAL | `-E` | Set to "True" to run the TEEHR automated evaluation service on NextGen outputs. | |
| VERBOSE | `-V` | Set to "True" to output all of forcingprocessor and NGIAB outputs | |
| LSTM_ENS_MEMBERS |`-L` | List of integers corresponding to the LSTM ens members bewlow, for example 025| |

Expand Down
15 changes: 0 additions & 15 deletions scripts/datastream
Original file line number Diff line number Diff line change
Expand Up @@ -116,7 +116,6 @@ usage() {
echo " -o, --S3_PREFIX <File prefix within s3 bucket> "
echo " -n, --NPROCS <Process limit> "
echo " -y, --DRYRUN <True to skip calculations> "
echo " -E, --EVAL <True to run TEEHR evaluation service> "
echo " -L, --LSTM_ENS_MEMBERS <LSTM ensemble members. 012345> "
exit 0
}
Expand All @@ -143,7 +142,6 @@ S3_BUCKET=""
S3_PREFIX=""
NPROCS=4
DRYRUN="False"
DO_TEEHR="False"
VERBOSE="False"
PIPE=""
if [[ $VERBOSE == "True" ]]; then
Expand All @@ -165,12 +163,10 @@ VERSIONS_INTEGRATIONS_FILE=$PACKAGE_DIR/versions_integrations.yml
DS_TAG=${DS_TAG:-$(sed -n 's/^datastream: *"\([^"]*\)".*/\1/p' "$VERSIONS_FILE")}
FP_TAG=${FP_TAG:-$(sed -n 's/^forcingprocessor: *"\([^"]*\)".*/\1/p' "$VERSIONS_INTEGRATIONS_FILE")}
NGIAB_TAG=${NGIAB_TAG:-$(sed -n 's/^ciroh-ngen-image: *"\([^"]*\)".*/\1/p' "$VERSIONS_INTEGRATIONS_FILE")}
TEEHR_TAG=${TEEHR_TAG:-$(sed -n 's/^ngiab-teehr: *"\([^"]*\)".*/\1/p' "$VERSIONS_INTEGRATIONS_FILE")}
echo "Image Tags:"
echo " DS_TAG: $DS_TAG"
echo " FP_TAG: $FP_TAG"
echo " NGIAB_TAG: $NGIAB_TAG"
echo " TEEHR_TAG: $TEEHR_TAG"

FORCING_SOURCE_OPTIONS=("NWM_RETRO_V2" "NWM_RETRO_V3" "NWM_OPERATIONAL_V3" "NOMADS_OPERATIONAL")
if is_in_list "$FORCING_SOURCE" "${FORCING_SOURCE_OPTIONS[@]}"; then
Expand Down Expand Up @@ -211,7 +207,6 @@ while [ "$#" -gt 0 ]; do
-o|--S3_PREFIX) S3_PREFIX="$2"; shift 2;;
-n|--NPROCS) NPROCS="$2"; shift 2;;
-y|--DRYRUN) DRYRUN="$2"; shift 2;;
-E|--EVAL) EVAL="$2"; shift 2;;
-V|--VERBOSE) VERBOSE="$2"; shift 2;;
-L|--LSTM_ENS_MEMBERS) LSTM_ENS_MEMBERS="$2"; shift 2;;
*) usage;;
Expand Down Expand Up @@ -774,28 +769,18 @@ log_time "MERKLE_END"
# log_time "TAR_END"
# fi

if [ "$EVAL" == "True" ]; then
log_time "EVAL_START"
TEEHR_DOCKER=awiciroh/ngiab-teehr
log_n_run_steps docker run -v "$NGEN_RUN:/app/data" "$TEEHR_DOCKER:$TEEHR_TAG"
TEEHR_HASH=$(docker inspect --format='{{json .Id}}' $(docker image ls "$TEEHR_DOCKER:$TEEHR_TAG" --format "{{.ID}}") | tr -d '"')
log_time "EVAL_END"
fi

echo "sha256 hashes:"
echo "DATASTREAM DOCKER " $DS_HASH
echo "FORCINGPROCESSOR DOCKER " $FP_HASH
echo "NGIAB DOCKER " $NGIAB_HASH
echo "MERKDIR DOCKER " $MERK_HASH
echo "TEEHR DOCKER " $TEEHR_HASH
echo "STREAM SCRIPT " $STREAM_HASH

HASHES=$DATASTREAM_META/docker_hashes.txt
echo "DATASTREAM DOCKER: $DS_HASH" >> $HASHES
echo "FORCINGPROCESSOR DOCKER: $FP_HASH" >> $HASHES
echo "NGIAB DOCKER: $NGIAB_HASH" >> $HASHES
echo "MERKDIR DOCKER: $MERK_HASH" >> $HASHES
echo "TEEHR DOCKER: $TEEHR_HASH" >> $HASHES
echo "STREAM SCRIPT: $STREAM_HASH" >> $HASHES

log_time "DATASTREAM_END"
Expand Down
8 changes: 2 additions & 6 deletions scripts/datastream_guide
Original file line number Diff line number Diff line change
Expand Up @@ -322,11 +322,10 @@ pause
echo ""
echo ""

echo "and cli args that manage compute and run the TEEHR evaluation service"
echo "and cli args that manage compute"
echo "
-n, --NPROCS <Process limit>
-n, --NPROCS <Process limit>
-y, --DRYRUN <True to skip calculations>
-E, --EVAL <True to run TEEHR evaluation service>
"
pause
echo ""
Expand Down Expand Up @@ -371,7 +370,6 @@ read -p "Enter S3_BUCKET (S3 bucket to write output to, leave blank to skip): "
read -p "Enter S3_PREFIX (File prefix within S3 bucket, leave blank to skip): " S3_PREFIX
read -p "Set NPROCS (Maximum number of processes, leave blank for default): " NPROCS
read -p "Enable DRYRUN? (Enter 'True' to skip calculations, leave blank to perform calculations): " DRYRUN
read -p "Run TEEHR? (Enter 'True' to run TEEHR evaluation service, leave blank to skip TEEHR): " EVAL

# Summarize user input
echo ""
Expand All @@ -392,7 +390,6 @@ echo "Configuration summary:"
[[ -n $S3_PREFIX ]] && echo "- S3_PREFIX: $S3_PREFIX"
[[ -n $NPROCS ]] && echo "- NPROCS: $NPROCS"
[[ -n $DRYRUN ]] && echo "- DRYRUN: $DRYRUN"
[[ -n $EVAL ]] && echo "- EVAL: $EVAL"
echo ""
echo ""
echo "All required configurations have been completed."
Expand Down Expand Up @@ -420,7 +417,6 @@ cmd="./scripts/datastream"
[ -n "$S3_PREFIX" ] && cmd="$cmd -o \"$S3_PREFIX\""
[ -n "$NPROCS" ] && cmd="$cmd -n \"$NPROCS\""
[ -n "$DRYRUN" ] && cmd="$cmd -y \"$DRYRUN\""
[ -n "$EVAL" ] && cmd="$cmd -E \"$EVAL\""
echo ""
echo "The following command will be executed:"
echo "$cmd"
Expand Down
1 change: 0 additions & 1 deletion versions_integrations.yml
Original file line number Diff line number Diff line change
@@ -1,3 +1,2 @@
forcingprocessor: "2.2.1"
ciroh-ngen-image: "v1.8.0"
ngiab-teehr: "latest"
Loading