Merge pull request #487 from endeepak/fix472

#472 : Fix oracle exception
2015-06-13 14:53:02 +03:00 · 2015-06-13 14:53:02 +03:00 · 29c31780c6
parent d1decb5033 f625dc5168
commit 29c31780c6
1 changed files with 2 additions and 0 deletions
--- a/kombu/transport/django/managers.py
+++ b/kombu/transport/django/managers.py
@ -53,6 +53,8 @@ class QueueManager(models.Manager):


 def select_for_update(qs):
+    if connection.vendor == 'oracle':
+        return qs
    try:
        return qs.select_for_update()
    except AttributeError: