处理 pytest 失败断言的最佳实践

Question

我使用 pyspark、EMR、terraform 和气流进行触发。我正在我的 pyspark 代码中编写 pytest 用例。我有以下问题：

I）如果我得到“False”断言。我正在考虑发送松弛和电子邮件通知并关闭 EMR 集群。这是每个人都遵循的最佳实践吗？ 。

有人可以解释如何在断言失败的情况下处理 pytests 吗？或处理 pytest 失败的一般方法

示例代码：

def task_fail_slack_alert(context):
    SLACK_CONN_ID = 'slack'
    slack_webhook_token = BaseHook.get_connection(SLACK_CONN_ID).password
    slack_msg = """
            :red_circle: crunchbase Job Failed.
            *Task*: {task}
            *Dag*: {dag}
            *Execution Time*: {exec_date}
            *Log Url*: {log_url}
            *Error*:{exception}
            """.format(
            task=context.get('task_instance').task_id,
            dag=context.get('task_instance').dag_id,
            exec_date=context.get('execution_date'),
            log_url=context.get('task_instance').log_url,
            exception=context.get('exception')

        )
    failed_alert = SlackWebhookOperator(
        task_id='slack',
        http_conn_id='slack',
        webhook_token=slack_webhook_token,
        message=slack_msg,
        username='airflow_sld',
        dag=dag)
    return failed_alert.execute(context=context)