def get_emr_response()

in airflow_dag_for_execution/simple_dag.py [0:0]

• 4 lines of code
• 1 McCabe index (conditional complexity)

    def get_emr_response(self):
        emr = EmrHook(aws_conn_id=self.aws_conn_id).get_conn()
        self.log.info('Poking notebook execution %s', self.notebook_execution_id)
        return emr.describe_notebook_execution(NotebookExecutionId=self.notebook_execution_id)