burmatovan/openuds
1
0
Fork 0
forked from shaba/openuds
Code Issues Pull Requests Projects Releases Wiki Activity

Added "connection.close" to release used connections early" (fixed)

Browse Source
This commit is contained in:
Adolfo Gómez García 2020-09-29 16:16:47 +02:00
parent e184961eba
commit 1789aee1e7
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/src/uds/core/jobs/delayed_task_runner.py
View File

@ -37,7 +37,7 @@ from socket import gethostname
from datetime import timedelta from datetime import timedelta
from django.db import connections from django.db import connections
from django.db import transaction, connection from django.db import transaction
from django.db.models import Q from django.db.models import Q
from uds.models import DelayedTask as DBDelayedTask from uds.models import DelayedTask as DBDelayedTask
@ -152,7 +152,7 @@ class DelayedTaskRunner:
except Exception as e: except Exception as e:
logger.info('Exception inserting a delayed task %s: %s', e.__class__, e) logger.info('Exception inserting a delayed task %s: %s', e.__class__, e)
try: try:
connection.close() connections['default'].close()
except Exception: except Exception:
logger.exception('Closing db connection at insert') logger.exception('Closing db connection at insert')
time.sleep(1) # Wait a bit before next try... time.sleep(1) # Wait a bit before next try...
@ -190,7 +190,7 @@ class DelayedTaskRunner:
except Exception as e: except Exception as e:
logger.error('Unexpected exception at run loop %s: %s', e.__class__, e) logger.error('Unexpected exception at run loop %s: %s', e.__class__, e)
try: try:
connection.close() connections['default'].close()
except Exception: except Exception:
logger.exception('Exception clossing connection at delayed task') logger.exception('Exception clossing connection at delayed task')
logger.info('Exiting DelayedTask Runner because stop has been requested') logger.info('Exiting DelayedTask Runner because stop has been requested')