Skip to content

Commit

Permalink
Formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
SeanBryan51 committed May 9, 2024
1 parent e267278 commit ddb8b70
Showing 1 changed file with 13 additions and 3 deletions.
16 changes: 13 additions & 3 deletions src/benchcab/benchcab.py
Original file line number Diff line number Diff line change
Expand Up @@ -297,8 +297,13 @@ def fluxsite_run_tasks(self, config_path: str):
n_sites = len(get_met_forcing_file_names(config["fluxsite"]["experiment"]))
n_science_configurations = len(config["science_configurations"])

Check warning on line 298 in src/benchcab/benchcab.py

View check run for this annotation

Codecov / codecov/patch

src/benchcab/benchcab.py#L296-L298

Added lines #L296 - L298 were not covered by tests

logger.info(f"Running fluxsite tasks...")
logger.info(f"tasks: {len(tasks)} (models: {n_models}, sites: {n_sites}, science configurations: {n_science_configurations})")
logger.info("Running fluxsite tasks...")
logger.info(

Check warning on line 301 in src/benchcab/benchcab.py

View check run for this annotation

Codecov / codecov/patch

src/benchcab/benchcab.py#L301

Added line #L301 was not covered by tests
f"tasks: {len(tasks)} "
f"(models: {n_models}, "
f"sites: {n_sites}, "
f"science configurations: {n_science_configurations})"
)
if config["fluxsite"]["multiprocess"]:
ncpus = config["fluxsite"]["pbs"]["ncpus"]
fluxsite.run_tasks_in_parallel(tasks, n_processes=ncpus)
Expand Down Expand Up @@ -329,7 +334,12 @@ def fluxsite_bitwise_cmp(self, config_path: str):
n_science_configurations = len(config["science_configurations"])

Check warning on line 334 in src/benchcab/benchcab.py

View check run for this annotation

Codecov / codecov/patch

src/benchcab/benchcab.py#L332-L334

Added lines #L332 - L334 were not covered by tests

logger.info("Running comparison tasks...")
logger.info(f"tasks: {len(comparisons)} (models: {n_models}, sites: {n_sites}, science configurations: {n_science_configurations})")
logger.info(

Check warning on line 337 in src/benchcab/benchcab.py

View check run for this annotation

Codecov / codecov/patch

src/benchcab/benchcab.py#L337

Added line #L337 was not covered by tests
f"tasks: {len(comparisons)} "
f"(models: {n_models}, "
f"sites: {n_sites}, "
f"science configurations: {n_science_configurations})"
)
if config["fluxsite"]["multiprocess"]:
ncpus = config["fluxsite"]["pbs"]["ncpus"]
run_comparisons_in_parallel(comparisons, n_processes=ncpus)
Expand Down

0 comments on commit ddb8b70

Please sign in to comment.