add to_generator()
MODIFY
pangeo_forge_recipes/recipes/base.py
pangeo_forge_recipes/recipes/base.py
@@ -17,6 +17,11 @@ class BaseRecipe(ABC):
return FunctionPipelineExecutor.compile(self._compiler())
+ def to_generator(self):
+ from ..executors import GeneratorPipelineExecutor
+
+ return GeneratorPipelineExecutor.compile(self._compiler())
+
def to_dask(self):
from pangeo_forge_recipes.executors import DaskPipelineExecutor

add to_generator()