From 1bf498d15c337226cc8e7d8415f03d622be2cbf8 Mon Sep 17 00:00:00 2001 From: caoqianming Date: Fri, 5 Jul 2024 10:46:33 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20base=20thread=E6=B7=BB=E5=8A=A0=E6=97=A5?= =?UTF-8?q?=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/utils/thread.py | 24 +++++------------------- 1 file changed, 5 insertions(+), 19 deletions(-) diff --git a/apps/utils/thread.py b/apps/utils/thread.py index bd47c8b4..5276955e 100644 --- a/apps/utils/thread.py +++ b/apps/utils/thread.py @@ -1,23 +1,9 @@ import threading -import logging -from apps.utils.tasks import send_mail_task -import traceback - -logger = logging.getLogger('log') +from apps.utils.decorators import auto_log class MyThread(threading.Thread): - def __init__(self, log_err=False, send_err=False): - super().__init__() - self.send_err = send_err - self.log_err = log_err - def run(self): - try: - if self._target: - self._target(*self._args, **self._kwargs) - except Exception as e: - if self.log_err: - logger.error(f"Thread error: {e}", exc_info=False) - if self.send_err: - send_mail_task.delay(message=traceback.format_exc()) - raise \ No newline at end of file + @auto_log('MyThread', raise_exception=True, send_mail=True) + def run(self) -> None: + return super().run() + \ No newline at end of file