airflow.providers.papermill.operators.papermill

Module Contents

class airflow.providers.papermill.operators.papermill.NoteBook[source]

Bases: airflow.lineage.entities.File

Jupyter notebook

type_hint :Optional[str] = jupyter_notebook[source]
parameters :Optional[Dict][source]
meta_schema :str[source]
class airflow.providers.papermill.operators.papermill.PapermillOperator(*, input_nb: Optional[str] = None, output_nb: Optional[str] = None, parameters: Optional[Dict] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Executes a jupyter notebook through papermill that is annotated with parameters

Parameters

  • input_nb (str) -- input notebook (can also be a NoteBook or a File inlet)

  • output_nb (str) -- output notebook (can also be a NoteBook or File outlet)

  • parameters (dict) -- the notebook parameters to set

supports_lineage = True[source]
template_fields = ['input_nb', 'output_nb', 'parameters'][source]
execute(self, context)[source]

Was this entry helpful?