fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-08 15:08:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

Check for the right database when querying for get_autocommit

Browse Source
This commit is contained in:
Martijn Jacobs
2020-05-01 17:29:27 +02:00
parent 108050b1ea
commit 85a9f33ac0
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/brokers/orm.py
+1 -1
View File
@@ -17,7 +17,7 @@ def _timeout():
class ORM(Broker): class ORM(Broker):
@staticmethod @staticmethod
def get_connection(list_key=Conf.PREFIX): def get_connection(list_key=Conf.PREFIX):
if transaction.get_autocommit(): # Only True when not in an atomic block if transaction.get_autocommit(using=Conf.ORM): # Only True when not in an atomic block
# Make sure stale connections in the broker thread are explicitly # Make sure stale connections in the broker thread are explicitly
# closed before attempting DB access. # closed before attempting DB access.
# logger.debug("Broker thread calling close_old_connections") # logger.debug("Broker thread calling close_old_connections")