`airflow.operators.papermill_operator`¶

Module Contents¶

class airflow.operators.papermill_operator.NoteBook[source]¶

Bases: airflow.lineage.datasets.DataSet

type_name = jupyter_notebook[source]¶

attributes = ['location', 'parameters'][source]¶

class airflow.operators.papermill_operator.PapermillOperator(input_nb, output_nb, parameters, *args, **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

execute(self, context)[source]¶

Was this entry helpful?