diff --git a/src/radclss/core/radclss_core.py b/src/radclss/core/radclss_core.py index 9be6799..7c70b46 100644 --- a/src/radclss/core/radclss_core.py +++ b/src/radclss/core/radclss_core.py @@ -563,6 +563,7 @@ def _get_nexrad_wrapper(time_str): print("Variables in merged dataset:") for vars in ds_concat.data_vars: print(vars) + ds = act.io.create_ds_from_arm_dod( f"{output_platform}.{output_level}", { diff --git a/tests/test_radclss.py b/tests/test_radclss.py index e1c5617..6de8b2c 100644 --- a/tests/test_radclss.py +++ b/tests/test_radclss.py @@ -79,8 +79,7 @@ def test_radclss_serial(): "S40": (34.17932, -87.45349, 236), "S13": (34.343889, -87.350556, 286), } - radclss.core.set_output_platform("radclss") - radclss.core.set_output_level("c0") + my_columns = radclss.core.radclss( volumes, input_site_dict, "radar_csapr2", serial=True, verbose=False ) @@ -258,8 +257,7 @@ def test_radclss_parallel(): "S40": (34.17932, -87.45349, 236), "S13": (34.343889, -87.350556, 286), } - radclss.core.set_output_platform("radclss") - radclss.core.set_output_level("c0") + with Client(LocalCluster(n_workers=2, threads_per_worker=1)) as client: # noqa my_columns = radclss.core.radclss( volumes, input_site_dict, "radar_csapr2", serial=False, verbose=False