Попытка вызвать исключение в DAG воздушного потока и получение «сломанного DAG»

#python-3.x #airflow Вопрос: Я хочу, чтобы мой DAG вышел из строя (во время работы), если значение cursor.rowcount > 0 равно true. Это и есть код: def execute(self): self.hook = PostgresHook(postgres_conn_id=self.dest_redshift_conn_id)…