diff --git a/src/daemon/dispatcher.py b/src/daemon/dispatcher.py index 5da768d..8d73093 100644 --- a/src/daemon/dispatcher.py +++ b/src/daemon/dispatcher.py @@ -698,6 +698,12 @@ class Dispatcher: ) conn.commit() logger.info("Mail %s: marked failed (no_reply_found)", task_id) + # Mail 失败通知:通知发件人 + try: + from src.daemon.mail_notify import notify_mail_failed + notify_mail_failed(db_path, task_id, "no_reply_found") + except Exception as ne: + logger.warning("Mail %s: failed to send no_reply_found notification: %s", task_id, ne) return finally: conn.close()