flowserv.controller.worker.notebook module
- class flowserv.controller.worker.notebook.NotebookEngine(identifier: Optional[str] = None, env: Optional[Dict] = None, volume: Optional[str] = None)
Bases:
flowserv.controller.worker.base.WorkerExecution engine for notebook steps in a serial workflow.
- exec(step: flowserv.model.workflow.step.NotebookStep, context: Dict, store: flowserv.volume.fs.FileSystemStorage) flowserv.controller.serial.workflow.result.ExecResult
Execute a given notebook workflow step in the current workflow context.
The notebook engine expects a file system storage volume that provides access to the notebook file and any other aditional input files.
- Parameters
step (flowserv.model.workflow.step.NotebookStep) – Notebook step in a serial workflow.
context (dict) – Dictionary of variables that represent the current workflow state.
store (flowserv.volume.fs.FileSystemStorage) – Storage volume that contains the workflow run files.
- Return type