in airflow_dag_for_execution/simple_dag.py [0:0]
def failure_message_from_response(response):
state_change_reason = response['NotebookExecution']['LastStateChangeReason']
if state_change_reason:
return 'Execution failed with reason: ' + state_change_reason
return None