Skip to content

Commit a821e11

Browse files
committed
Fix rebase issues
1 parent ba70873 commit a821e11

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

e3sm_diags/e3sm_diags_driver.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -330,7 +330,7 @@ def _run_serially(parameters: list[CoreParameter]) -> list[CoreParameter]:
330330
return collapsed_results
331331

332332

333-
def _run_with_dask(parameters: list[CoreParameter]) -> list[CoreParameter]:
333+
def _run_with_dask_bag(parameters: list[CoreParameter]) -> list[CoreParameter]:
334334
"""Run diagnostics with the parameters in parallel using Dask.
335335
336336
This function passes ``run_diag`` to ``dask.bag.map``, which gets executed
@@ -410,7 +410,7 @@ def _run_with_dask_distributed(
410410
return collapsed_results
411411

412412

413-
def _collapse_results(parameters: List[List[CoreParameter]]) -> List[CoreParameter]:
413+
def _collapse_results(parameters: list[list[CoreParameter]]) -> list[CoreParameter]:
414414
"""Collapses the results of diagnostic runs by one list level.
415415
416416
Parameters

0 commit comments

Comments
 (0)