boilercv_pipeline.nbs

Notebook operations.

Module Contents

Functions

apply_to_nb	Apply a process to a notebook.
submit_nb_process	Submit a notebook process to an executor.
callbacks	Apply a series of done callbacks to the future.

API

boilercv_pipeline.nbs.apply_to_nb(

nb: str,

params: boilercv_pipeline.models.params.DataParams[boilercv_pipeline.models.stage.Deps, boilercv_pipeline.models.stage.Outs, boilercv_pipeline.models.params.types.Data_T],

**kwds: Any,

) → boilercv_pipeline.models.params.types.Data_T

Apply a process to a notebook.

boilercv_pipeline.nbs.submit_nb_process(

executor: concurrent.futures.ProcessPoolExecutor,

nb: str,

params: boilercv_pipeline.models.params.DataParams[boilercv_pipeline.models.stage.Deps, boilercv_pipeline.models.stage.Outs, boilercv_pipeline.models.params.types.Data_T],

**kwds: Any,

) → concurrent.futures.Future[boilercv_pipeline.models.params.types.Data_T]

Submit a notebook process to an executor.

boilercv_pipeline.nbs.callbacks(

future: concurrent.futures.Future[boilercv_pipeline.models.params.types.Data_T],

/,

callbacks: collections.abc.Iterable[collections.abc.Callable[[concurrent.futures.Future[boilercv_pipeline.models.params.types.Data_T]], None]],

)

Apply a series of done callbacks to the future.