fix db connection
Showing
1 changed file
with
2 additions
and
0 deletions
... | @@ -11,6 +11,7 @@ import requests | ... | @@ -11,6 +11,7 @@ import requests |
11 | import traceback | 11 | import traceback |
12 | from collections import Counter | 12 | from collections import Counter |
13 | from datetime import datetime, date | 13 | from datetime import datetime, date |
14 | from django import db | ||
14 | from django.utils import timezone | 15 | from django.utils import timezone |
15 | from django.core.management import BaseCommand | 16 | from django.core.management import BaseCommand |
16 | from multiprocessing import Process, Queue, Manager, Lock | 17 | from multiprocessing import Process, Queue, Manager, Lock |
... | @@ -731,6 +732,7 @@ class Command(BaseCommand, LoggerMixin): | ... | @@ -731,6 +732,7 @@ class Command(BaseCommand, LoggerMixin): |
731 | # EDMS异常:下载异常-->回队列-->邮件;上传异常-->重新上传队列-->邮件 | 732 | # EDMS异常:下载异常-->回队列-->邮件;上传异常-->重新上传队列-->邮件 |
732 | # 算法异常:第一道异常-->识别失败-->邮件;第二道异常-->识别失败-->邮件 | 733 | # 算法异常:第一道异常-->识别失败-->邮件;第二道异常-->识别失败-->邮件 |
733 | def handle(self, *args, **kwargs): | 734 | def handle(self, *args, **kwargs): |
735 | db.close_old_connections() | ||
734 | lock = Lock() | 736 | lock = Lock() |
735 | with Manager() as manager: | 737 | with Manager() as manager: |
736 | error_list = manager.list() | 738 | error_list = manager.list() | ... | ... |
-
Please register or sign in to post a comment