run test_lock_timeout without dask
MODIFY
tests/test_recipes.py
tests/test_recipes.py
@@ -294,19 +294,18 @@ def test_chunks(
xr.testing.assert_identical(ds_actual, ds_expected)
-def test_lock_timeout(netCDFtoZarr_recipe_sequential_only, execute_recipe):
+def test_lock_timeout(netCDFtoZarr_recipe_sequential_only, execute_recipe_no_dask):
RecipeClass, file_pattern, kwargs, ds_expected, target = netCDFtoZarr_recipe_sequential_only
recipe = RecipeClass(file_pattern=file_pattern, lock_timeout=1, **kwargs)
with patch("pangeo_forge_recipes.recipes.xarray_zarr.lock_for_conflicts") as p:
- execute_recipe(recipe)
-
# We can only check that the mock object is called with the right parameters if
# the function is called in the same processes as our mock object. We can't
# observe anything that happens when the function is executed in subprocess, i.e.
# if we're using a Dask executor.
- if execute_recipe.param in {"manual", "python", "prefect"}:
+ execute_recipe_no_dask(recipe)
+
assert p.call_args[1]["timeout"] == 1

run test_lock_timeout without dask