in airflow_dag_for_execution/simple_dag.py [0:0]
def __init__(self, notebook_execution_id, *args, **kwargs): super(NotebookExecutionSensor, self).__init__(*args, **kwargs) self.notebook_execution_id = notebook_execution_id