fix queue exception handling
This commit is contained in:
@@ -16,6 +16,7 @@ import logging
|
|||||||
import smtplib
|
import smtplib
|
||||||
|
|
||||||
from multiprocessing import Process, Queue
|
from multiprocessing import Process, Queue
|
||||||
|
from queue import Full as QueueFull
|
||||||
|
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
||||||
@@ -82,5 +83,5 @@ def sendmail(smtp_host, smtp_port, qid, mailfrom, recipients, mail,
|
|||||||
(smtp_host, smtp_port, qid, mailfrom, recipient, mail,
|
(smtp_host, smtp_port, qid, mailfrom, recipient, mail,
|
||||||
emailtype),
|
emailtype),
|
||||||
timeout=30)
|
timeout=30)
|
||||||
except Queue.Full:
|
except QueueFull:
|
||||||
raise RuntimeError("email queue is full")
|
raise RuntimeError("email queue is full")
|
||||||
|
|||||||
Reference in New Issue
Block a user